From 554a37b2a9e09546f8c061d54cbf013086411ee7 Mon Sep 17 00:00:00 2001 From: Nitin Date: Tue, 27 Jul 2021 14:14:01 +0530 Subject: [PATCH] DE-121 - added env variable --- producer/producer_config.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/producer/producer_config.go b/producer/producer_config.go index e66602d..b7d4e1c 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -49,7 +49,7 @@ func GetAsyncProducerConfig(kafkaConfiguration config.KafkaConfigurations, env s //kafkaConfiguration configuration.KafkaConfigurations // security configs // config.Net.TLS.Enable = true - if env != "PROD" { + if env == "PROD" { config.Net.SASL.Enable = true config.Net.SASL.Handshake = true config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512