DE-121 - added env variable

2021-07-27 14:14:01 +05:30
parent 3d3200d381
commit 554a37b2a9
1 changed files with 1 additions and 1 deletions
--- 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