add log when create simple_consumer

childe · Jul 9, 2024 · 236d297 · 236d297
1 parent 6020886
commit 236d297
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/simple_consumer.go b/simple_consumer.go
@@ -95,6 +95,7 @@ func NewSimpleConsumer(topic string, partitionID int32, config interface{}) (*Si
 
 	brokerConfig := getBrokerConfigFromConsumerConfig(cfg)
 
+	logger.Info("create simple consumer", "topic", topic, "partitionID", partitionID, "config", cfg, "brokerConfig", brokerConfig)
 	brokers, err := NewBrokersWithConfig(cfg.BootstrapServers, brokerConfig)
 	if err != nil {
 		return nil, err