commit

amd64/dispatch_server/main.go

@@ -56,7 +56,7 @@ func init() {
 	}
 
 	// 6 初始化 kafka 客户端
-	infra.InitKafkaProducer([]string{"localhost:9092"})
+	infra.InitKafkaProducer(infra.ApplicationYaml.Kafka.Broker)
 
 }
 

amd64/dispatch_server/package/infra/application.yaml

@@ -18,8 +18,7 @@ redis:
 
 kafka:
   partition: 0
-  brokers:
-    - 10.14.85.239:9092
+  broker: 10.14.85.239:9092
 
 oss:
   type: Aliyun # Minio 或 Aliyun

amd64/dispatch_server/package/infra/i_application.go

@@ -37,8 +37,8 @@ type RedisStruct struct {
 }
 
 type KafkaStruct struct {
-	Partition int32    `yaml:"partition"`
-	Brokers   []string `yaml:"brokers"`
+	Partition int32  `yaml:"partition"`
+	Broker    string `yaml:"broker"`
 }
 
 type OssStruct struct {

amd64/dispatch_server/package/infra/i_kafka.go

@@ -8,10 +8,10 @@ import (
 var GlobalKafkaProducer *kafka.Producer
 
 // 初始化Kafka生产者的函数
-func InitKafkaProducer(brokers []string) {
+func InitKafkaProducer(broker string) {
 	// 创建配置
 	conf := &kafka.ConfigMap{
-		"bootstrap.servers": brokers,
+		"bootstrap.servers": broker,
 		"client.id":         "kafka-client-cicv-data-closedloop",
 	}
 
@@ -19,6 +19,6 @@ func InitKafkaProducer(brokers []string) {
 	var err error
 	GlobalKafkaProducer, err = kafka.NewProducer(conf)
 	if err != nil {
-		GlobalLogger.Errorf("初始化kafka生产者失败，配置信息为：%v，错误信息为：%v", brokers, err)
+		GlobalLogger.Errorf("初始化kafka生产者失败，配置信息为：%v，错误信息为：%v", broker, err)
 	}
 }

amd64/dispatch_server/package/service/run_task.go

@@ -196,7 +196,7 @@ func RunWaitingCluster() {
 		podString = strings.Replace(podString, "oss-ip", infra.ApplicationYaml.Oss.Endpoint, -1) // 不带http://前缀
 		podString = strings.Replace(podString, "oss-access-key", infra.ApplicationYaml.Oss.AccessKeyId, -1)
 		podString = strings.Replace(podString, "oss-secret-key", infra.ApplicationYaml.Oss.AccessKeySecret, -1)
-		podString = strings.Replace(podString, "kafka-ip", infra.ApplicationYaml.Kafka.Brokers[0], -1)
+		podString = strings.Replace(podString, "kafka-ip", infra.ApplicationYaml.Kafka.Broker, -1)
 		podString = strings.Replace(podString, "kafka-topic", projectId, -1)
 		podString = strings.Replace(podString, "kafka-partition", "\""+util.ToString(infra.ApplicationYaml.Kafka.Partition)+"\"", -1)
 		podString = strings.Replace(podString, "kafka-offset", "\""+util.ToString(offset)+"\"", -1)