pet_home/pet_home_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

系统优化

Browse Source
This commit is contained in:
hahwu 2025-03-19 16:20:31 +08:00
parent 09ac4e46e8
commit 3588490801
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/server/conf/server.json
View File

@ -31,5 +31,5 @@
"GoogleVerify":true, "GoogleVerify":true,
"RemoteAddr":"host.docker.internal:9001", "RemoteAddr":"host.docker.internal:9001",
"Partition":1 "Partition":3
} }

2
src/server/middleware/kafka/kafka.go
View File

@ -15,7 +15,7 @@ var topic string
func init() { func init() {
topic = conf.Server.GameName topic = conf.Server.GameName
// 连接至Kafka集群的Leader节点 // 连接至Kafka集群的Leader节点
conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, 0) conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server-3:9096", topic, conf.Server.Partition)
if err != nil { if err != nil {
log.Debug("kafka.DialLeader err: %v", err) log.Debug("kafka.DialLeader err: %v", err)
go reconnectKafka() go reconnectKafka()