From 903559ca2a0130d8166355a3d59c87cfc932e368 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Wed, 19 Mar 2025 18:00:30 +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/json.go              |  2 +-
 src/server/middleware/kafka/kafka.go | 12 ++++++------
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/server/conf/json.go b/src/server/conf/json.go
index e9422aad..b74dc049 100644
--- a/src/server/conf/json.go
+++ b/src/server/conf/json.go
@@ -48,7 +48,7 @@ var Server struct {
 	TELOGDIR     string
 	GoogleVerify bool
 	Partition    int
-	KafkaAddr    string
+	KafkaHost    string
 	KafkaPort    string
 }
 
diff --git a/src/server/middleware/kafka/kafka.go b/src/server/middleware/kafka/kafka.go
index 0d924821..09d43f29 100644
--- a/src/server/middleware/kafka/kafka.go
+++ b/src/server/middleware/kafka/kafka.go
@@ -16,7 +16,7 @@ var topic string
 func init() {
 	topic = conf.Server.GameName
 	// 连接至Kafka集群的Leader节点
-	conn, err := kafka.DialContext(context.Background(), "tcp", fmt.Sprintf("%s:%s", conf.Server.KafkaAddr, conf.Server.KafkaPort))
+	conn, err := kafka.DialContext(context.Background(), "tcp", fmt.Sprintf("%s:%s", conf.Server.KafkaHost, conf.Server.KafkaPort))
 	if err != nil {
 		log.Debug("kafka.DialContext err: %v", err)
 		go reconnectKafka()
@@ -28,9 +28,9 @@ func init() {
 		return
 	}
 	for _, p := range Partitions {
-		if p.Leader.Host == conf.Server.KafkaAddr {
+		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.KafkaAddr, conf.Server.KafkaPort), topic, p.ID)
+			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)
 				return
@@ -51,7 +51,7 @@ func reconnectKafka() {
 			log.Debug("Reconnected to Kafka failed")
 			return
 		}
-		conn, err := kafka.DialContext(context.Background(), "tcp", fmt.Sprintf("%s:%s", conf.Server.KafkaAddr, conf.Server.KafkaPort))
+		conn, err := kafka.DialContext(context.Background(), "tcp", fmt.Sprintf("%s:%s", conf.Server.KafkaHost, conf.Server.KafkaPort))
 		if err != nil {
 			log.Fatal("kafka.DialContext err: %v", err)
 			return
@@ -59,8 +59,8 @@ func reconnectKafka() {
 		Partitions, err := conn.ReadPartitions(topic)
 
 		for _, p := range Partitions {
-			if p.Leader.Host == conf.Server.KafkaAddr {
-				conn, err := kafka.DialLeader(context.Background(), "tcp", fmt.Sprintf("%s:%s", conf.Server.KafkaAddr, conf.Server.KafkaPort), topic, p.ID)
+			if p.Leader.Host == conf.Server.KafkaHost {
+				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)
 					return