系统优化

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"
 }

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)