commit

amd64/dispatch_server/main.go

@@ -57,6 +57,8 @@ func init() {
 
 	// 6 初始化 kafka 客户端
 	infra.InitKafkaProducer(infra.ApplicationYaml.Kafka.Broker)
+	// 7 初始化 k8s 客户端
+	infra.InitKubernetesClient()
 
 }