add some log and reduce some log's level

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)

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
 }

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
 	}