From 13eb99f410f7d2592d76bcb1687391f9d1d47c18 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Wed, 19 Mar 2025 17:42:49 +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/middleware/kafka/kafka.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/server/middleware/kafka/kafka.go b/src/server/middleware/kafka/kafka.go
index 3d81d681..9508e11d 100644
--- a/src/server/middleware/kafka/kafka.go
+++ b/src/server/middleware/kafka/kafka.go
@@ -14,7 +14,7 @@ var KafkaMod *kafka.Conn
 var topic string
 
 const (
-	HOST = "kafka-server:9092"
+	HOST = "kafka-server"
 	PORT = "9092"
 )
 
@@ -34,6 +34,7 @@ func init() {
 	}
 	for _, p := range Partitions {
 		if p.Leader.Host == HOST {
+			log.Debug("Kafka connected partition :%v", p)
 			conn, err := kafka.DialLeader(context.Background(), "tcp", fmt.Sprintf("%s:%s", HOST, PORT), topic, p.ID)
 			if err != nil {
 				log.Fatal("kafka.DialLeader err: %v", err)