kafka

@@ -13,7 +13,7 @@ func Run() {
 	messageHandlerMap["demo-v1"] = Demo
 	messageHandlerMap["demo-v1"] = Demo
 	//"指定topic" => 对应的处理方法
 	//"指定topic" => 对应的处理方法
 	messageHandlerMap[constant.KAFKA_BUSINESS_TOPIC] = handle.SyncDataBusinessAdmin
 	messageHandlerMap[constant.KAFKA_BUSINESS_TOPIC] = handle.SyncDataBusinessAdmin
-	err := saramaConsumer.StartConsume(constant.KAFKA_HOSTS, constant.SERVICE_NAME, messageHandlerMap, log.Logger)
+	err := saramaConsumer.StartConsume(constant.KAFKA_HOSTS, constant.KAFKA_GROUP_ID, messageHandlerMap, log.Logger)
 	log.Logger.Error(err.Error())
 	log.Logger.Error(err.Error())
 }
 }