From 8b69869050ce9a0f895b360c38c6be2e4059e84f Mon Sep 17 00:00:00 2001 From: aishwarya-raimule Date: Mon, 30 Jan 2023 17:50:44 +0530 Subject: [PATCH] removed sarama logging --- producer/producer_config.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) 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)