From 76fd55d1d542ead11a210eaa8f5e7e845a062969 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Wed, 19 Mar 2025 15:52:14 +0800
Subject: [PATCH] 1

---
 src/server/middleware/kafka/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/server/middleware/kafka/kafka.go b/src/server/middleware/kafka/kafka.go
index e48052ad..cbf3e8a0 100644
--- a/src/server/middleware/kafka/kafka.go
+++ b/src/server/middleware/kafka/kafka.go
@@ -15,7 +15,7 @@ var topic string
 func init() {
 	topic = conf.Server.GameName
 	// 连接至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 {
 		log.Debug("kafka.DialLeader err: %v", err)
 		go reconnectKafka()