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