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)