diff --git a/brokers.go b/brokers.go
index 8cdbf36..a7bc154 100644
--- a/brokers.go
+++ b/brokers.go
@@ -38,6 +38,7 @@ func (brokers *Brokers) BrokersInfo() map[int32]*BrokerInfo {
 
 // NewBrokersWithConfig create a new broker with config
 func NewBrokersWithConfig(bootstrapServers string, config *BrokerConfig) (*Brokers, error) {
+	logger.Info("create new brokers", "bootstrapServers", bootstrapServers, "config", config)
 	clientID := "healer-newbrokers"
 	for _, brokerAddr := range strings.Split(bootstrapServers, ",") {
 		broker, err := NewBroker(brokerAddr, -1, config)
diff --git a/fetch_response.go b/fetch_response.go
index 21093f2..1a6a1a4 100644
--- a/fetch_response.go
+++ b/fetch_response.go
@@ -488,7 +488,7 @@ func (streamDecoder *fetchResponseStreamDecoder) streamDecode(ctx context.Contex
 	if streamDecoder.more {
 		streamDecoder.readAll()
 	}
-	logger.Info("decode fetch response done", "correlationID", streamDecoder.correlationID)
+	logger.V(5).Info("decode fetch response done", "correlationID", streamDecoder.correlationID)
 
 	return nil
 }
diff --git a/group_consumer.go b/group_consumer.go
index ff6118a..1cec5b4 100644
--- a/group_consumer.go
+++ b/group_consumer.go
@@ -48,6 +48,7 @@ type GroupConsumer struct {
 // NewGroupConsumer cretae a new GroupConsumer
 func NewGroupConsumer(topic string, config interface{}) (*GroupConsumer, error) {
 	cfg, err := createConsumerConfig(config)
+	logger.Info("create group consumer", "origin_config", config, "final_config", cfg)
 	if err != nil {
 		return nil, err
 	}