From 35884908010a6c2c8fdccc9d4072e2d95ed30b1e Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Wed, 19 Mar 2025 16:20:31 +0800
Subject: [PATCH] =?UTF-8?q?=E7=B3=BB=E7=BB=9F=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/conf/server.json          | 2 +-
 src/server/middleware/kafka/kafka.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/server/conf/server.json b/src/server/conf/server.json
index 1ce9a6a0..6d5ca858 100644
--- a/src/server/conf/server.json
+++ b/src/server/conf/server.json
@@ -31,5 +31,5 @@
 	"GoogleVerify":true,
 	
 	"RemoteAddr":"host.docker.internal:9001",
-	"Partition":1
+	"Partition":3
 }
diff --git a/src/server/middleware/kafka/kafka.go b/src/server/middleware/kafka/kafka.go
index cbf3e8a0..f23c7061 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, 0)
+	conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server-3:9096", topic, conf.Server.Partition)
 	if err != nil {
 		log.Debug("kafka.DialLeader err: %v", err)
 		go reconnectKafka()