From d17559c528bbc930c96955665dee3b876cf3f46f Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Mon, 23 May 2022 19:56:34 +0800
Subject: [PATCH] log

---
 pkg/common/kafka/consumer_group.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pkg/common/kafka/consumer_group.go b/pkg/common/kafka/consumer_group.go
index 3af714373..01b84e85e 100644
--- a/pkg/common/kafka/consumer_group.go
+++ b/pkg/common/kafka/consumer_group.go
@@ -8,6 +8,7 @@ package kafka
 
 import (
 	"context"
+	"fmt"
 	"github.com/Shopify/sarama"
 )
 
@@ -28,6 +29,7 @@ func NewMConsumerGroup(consumerConfig *MConsumerGroupConfig, topics, addr []stri
 	config.Version = consumerConfig.KafkaVersion
 	config.Consumer.Offsets.Initial = consumerConfig.OffsetsInitial
 	config.Consumer.Return.Errors = consumerConfig.IsReturnErr
+	fmt.Println("init address is ", addr, "topics is ", topics)
 	client, err := sarama.NewClient(addr, config)
 	if err != nil {
 		panic(err.Error())