diff --git a/producer/producer_config.go b/producer/producer_config.go index ab3b7c8..9ae7808 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -3,12 +3,9 @@ package producer import ( "com.navi.medici.janus/config" "com.navi.medici.janus/utils" - "go.uber.org/zap" - "log" - "crypto/tls" "github.com/Shopify/sarama" - "os" + "go.uber.org/zap" "strings" "time" ) @@ -98,7 +95,6 @@ func GetAsyncProducer(kafkaConfiguration config.KafkaConfigurations, env string) } func InitializeProducers(kafkaConfiguration config.KafkaConfigurations, env string) { - sarama.Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags) logger = utils.GetLogger() syncProducer = GetSyncProducer(kafkaConfiguration, env) asyncProducer = GetAsyncProducer(kafkaConfiguration, env)