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

1

Browse Source
This commit is contained in:
hahwu 2025-03-19 15:52:14 +08:00
parent aaa60b04db
commit 09ac4e46e8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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, conf.Server.Partition) conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, 0)
if err != nil { if err != nil {
log.Debug("kafka.DialLeader err: %v", err) log.Debug("kafka.DialLeader err: %v", err)
go reconnectKafka() go reconnectKafka()