恢复group配置

0108c3c7 · xiaoguang.xu · 637eef1e · 0108c3c7
Commit 0108c3c7 authored Mar 15, 2019 by xiaoguang.xu
Show whitespace changes
Inline Side-by-side

Showing with 2 additions and 2 deletions

kafka_conf.go service/conf/kafka_conf.go +2 -2

No files found.
--- a/service/conf/kafka_conf.go
+++ b/service/conf/kafka_conf.go
@@ -11,12 +11,12 @@ func HealthTopic() KafkaConf {
 	return KafkaConf{
 		GlobalConfig.Kafka.Brokers,
 		"quantGroup.tech.enoch.pro",
-		"quantGroup-enoch-agent-pro"}
+		"quantGroup-enoch-agent"}
 }

 func BraveTopic() KafkaConf {
 	return KafkaConf{
 		GlobalConfig.Kafka.Brokers,
 		"quantGroup.tech.brave.pro",
-		"enoch-group-pro"}
+		"enoch-group"}
 }