adding debug logs

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)
 }