Merge pull request #6 from medici/sasl_scram

DE-121 - added env variable
2021-07-27 14:15:54 +05:30
parent 324bb9e315 554a37b2a9
commit 1b239ff0cf
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