diff --git a/src/server/conf/json.go b/src/server/conf/json.go
index 904ef811..b0b45fe3 100644
--- a/src/server/conf/json.go
+++ b/src/server/conf/json.go
@@ -47,6 +47,7 @@ var Server struct {
 	GameConfPath string
 	TELOGDIR     string
 	GoogleVerify bool
+	Partition    int
 }
 
 func init() {
diff --git a/src/server/conf/server.json b/src/server/conf/server.json
index fe381005..1ce9a6a0 100644
--- a/src/server/conf/server.json
+++ b/src/server/conf/server.json
@@ -30,6 +30,6 @@
 	"RedisPwd"  :"",
 	"GoogleVerify":true,
 	
-	"RemoteAddr":"host.docker.internal:9001"
-	
+	"RemoteAddr":"host.docker.internal:9001",
+	"Partition":1
 }
diff --git a/src/server/middleware/kafka/kafka.go b/src/server/middleware/kafka/kafka.go
index 521bc959..e48052ad 100644
--- a/src/server/middleware/kafka/kafka.go
+++ b/src/server/middleware/kafka/kafka.go
@@ -14,10 +14,8 @@ var topic string
 
 func init() {
 	topic = conf.Server.GameName
-	partition := 0
-
 	// 连接至Kafka集群的Leader节点
-	conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, partition)
+	conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, conf.Server.Partition)
 	if err != nil {
 		log.Debug("kafka.DialLeader err: %v", err)
 		go reconnectKafka()