diff --git a/producer/producer_config.go b/producer/producer_config.go index 8152fe2..f6c665e 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -3,8 +3,8 @@ package producer import ( config "com.navi.medici.janus/config" - // "os" - // "log" + "os" + "log" "time" "strings" "github.com/Shopify/sarama" @@ -90,7 +90,7 @@ func GetAsyncProducer(kafkaConfiguration config.KafkaConfigurations) sarama.Asyn func InitializeProducers(kafkaConfiguration config.KafkaConfigurations) { - // sarama.Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags) + sarama.Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags) syncProducer = GetSyncProducer(kafkaConfiguration) asyncProducer = GetAsyncProducer(kafkaConfiguration) }