..

@@ -118,6 +118,7 @@ func (r *Runer) InitConsumer() error {
 	// khosts := []string{"192.168.0.252:9092", "192.168.0.251:9092", "192.168.0.250:9092"}
 	// khosts := []string{"192.168.0.252:9092", "192.168.0.251:9092", "192.168.0.250:9092"}
 	// groupid := "partnermg_dev"
 	// groupid := "partnermg_dev"
 	// topic := []string{"topic_test"}
 	// topic := []string{"topic_test"}
+	logs.Debug(r.msgConsumer.kafkaHosts, r.msgConsumer.groupId, r.msgConsumer.topics)
 	consumer, err := cluster.NewConsumer(r.msgConsumer.kafkaHosts, r.msgConsumer.groupId, r.msgConsumer.topics, clusterCfg)
 	consumer, err := cluster.NewConsumer(r.msgConsumer.kafkaHosts, r.msgConsumer.groupId, r.msgConsumer.topics, clusterCfg)
 	// consumer, err := cluster.NewConsumer(khosts, groupid, topic, clusterCfg)
 	// consumer, err := cluster.NewConsumer(khosts, groupid, topic, clusterCfg)
 	if err != nil {
 	if err != nil {