修改开发环境配置文件

main.go

@@ -35,8 +35,6 @@ func main() {
 	//初始化redis连接池
 	data.RedisPoolInit()
 
-	//go service.AgentClusterConsumer()
-	//go service.ClusterConsumer()
 	go service.AgentClusterConsumer(conf.HealthTopic(), service.HealthMessageHandler{})
 	go service.AgentClusterConsumer(conf.BraveTopic(), service.BraveMessageHandler{})
 	intPort, _ := strconv.Atoi(port)

service/conf/dev/conf.json

@@ -12,7 +12,7 @@
     "brokers": ["192.168.4.100:15091", "192.168.4.100:15092", "192.168.4.100:15093"]
   },
   "influx_db": {
-    "host": "http://localhost",
-    "port": "9001"
+    "host": "192.168.4.100",
+    "port": "8066"
   }
 }

service/conf/kafka_conf.go

 package conf
 
-var (
-	//agentBrokers    = []string{"192.168.4.100:15091", "192.168.4.100:15092", "192.168.4.100:15093"}
-	agentBrokers    = []string{"172.30.12.19:9092", "172.30.12.20:9092", "172.30.12.21:9092"}
-	agentKafkaTopic = "quantGroup.tech.enoch.pro"
-	agentKafkaGroup = "quantGroup-enoch-agent"
-)
 
 type KafkaConf struct {
 	Broker []string
@@ -15,14 +9,14 @@ type KafkaConf struct {
 
 func HealthTopic() KafkaConf {
 	return KafkaConf{
-		[]string{"172.30.12.19:9092", "172.30.12.20:9092", "172.30.12.21:9092"},
+		GlobalConfig.Kafka.Brokers,
 		"quantGroup.tech.enoch.pro",
 		"quantGroup-enoch-agent"}
 }
 
 func BraveTopic() KafkaConf {
 	return KafkaConf{
-		[]string{"172.30.12.19:9092", "172.30.12.20:9092", "172.30.12.21:9092"},
+		GlobalConfig.Kafka.Brokers,
 		"quantGroup.tech.brave.pro",
 		"enoch-group"}
 }