修改消费者组

main.go

@@ -26,7 +26,8 @@ func handlerKafkaMsg() {
 
 	//处理调用链条信息
 	braveTopic := global.Config.GetOrDefault(global.NamespaceTechSleuth, "tech.brave.kafkaTopic", "")
-	braveConsumer, err := global.KafkaRecver.NewConsumer(global.KafkaGroup, []string{braveTopic}, func(msg *sarama.ConsumerMessage) {
+
+	braveConsumer, err := global.KafkaRecver.NewConsumer("enoch-group", []string{braveTopic}, func(msg *sarama.ConsumerMessage) {
 		pointList, err := points.TraceBaseInfoToPoint(msg.Value)
 		if err != nil {
 			glog.Errorf("can not make trace point:", err)
@@ -42,7 +43,7 @@ func handlerKafkaMsg() {
 
 	//处理基本信息
 	healthTopic := global.Config.GetOrDefault(global.NamespaceTechSleuth, "tech.enoch.kafkaTopic", "")
-	healthConsumer, err := global.KafkaRecver.NewConsumer(global.KafkaGroup, []string{healthTopic}, func(msg *sarama.ConsumerMessage) {
+	healthConsumer, err := global.KafkaRecver.NewConsumer("quantGroup-enoch-agent", []string{healthTopic}, func(msg *sarama.ConsumerMessage) {
 		pointList, err := points.HostBaseInfoToPoint(msg.Value)
 		if err != nil {
 			glog.Errorf("can not make health point:", err)