系统优化

src/server/conf/server.json

@@ -31,5 +31,5 @@
 	"GoogleVerify":true,
 	
 	"RemoteAddr":"host.docker.internal:9001",
-	"Partition":1
+	"Partition":3
 }

src/server/middleware/kafka/kafka.go

@@ -15,7 +15,7 @@ var topic string
 func init() {
 	topic = conf.Server.GameName
 	// 连接至Kafka集群的Leader节点
-	conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, 0)
+	conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server-3:9096", topic, conf.Server.Partition)
 	if err != nil {
 		log.Debug("kafka.DialLeader err: %v", err)
 		go reconnectKafka()