From daf7152619c064b90b027183ababe3d4704dfc07 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Wed, 19 Mar 2025 18:20:16 +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 | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/server/conf/server.json b/src/server/conf/server.json
index 679480a8..34de2aa3 100644
--- a/src/server/conf/server.json
+++ b/src/server/conf/server.json
@@ -32,6 +32,6 @@
 	
 	"RemoteAddr":"host.docker.internal:9001",
 	"Partition":3,
-	"KafkaHost":"kafka-server",
+	"KafkaHost":"kafka-server-2",
 	"KafkaPort":"9092"
 }
diff --git a/src/server/middleware/kafka/kafka.go b/src/server/middleware/kafka/kafka.go
index 09d43f29..e6d68872 100644
--- a/src/server/middleware/kafka/kafka.go
+++ b/src/server/middleware/kafka/kafka.go
@@ -60,6 +60,7 @@ func reconnectKafka() {
 
 		for _, p := range Partitions {
 			if p.Leader.Host == conf.Server.KafkaHost {
+				log.Debug("Kafka connected partition :%v", p)
 				conn, err := kafka.DialLeader(context.Background(), "tcp", fmt.Sprintf("%s:%s", conf.Server.KafkaHost, conf.Server.KafkaPort), topic, p.ID)
 				if err != nil {
 					log.Fatal("kafka.DialLeader err: %v", err)