微调

@@ -15,7 +15,7 @@ var KafkaCfg KafkaConfig
 func init() {
 func init() {
 	KafkaCfg = KafkaConfig{
 	KafkaCfg = KafkaConfig{
 		Servers:    []string{"106.52.15.41:9092"},
 		Servers:    []string{"106.52.15.41:9092"},
-		ConsumerId: "partnermg_dev",
+		ConsumerId: "partnermg_local",
 	}
 	}
 	if os.Getenv("KAFKA_HOST") != "" {
 	if os.Getenv("KAFKA_HOST") != "" {
 		kafkaHost := os.Getenv("KAFKA_HOST")
 		kafkaHost := os.Getenv("KAFKA_HOST")