diff --git a/main.go b/main.go
index e175477..513b0b7 100644
--- a/main.go
+++ b/main.go
@@ -36,8 +36,8 @@ func init() {
 
 	// Following coinfigurations read from environment variables
 	configuration.Kafka.Bootstrap_Servers = viper.GetString(configuration.Kafka.Bootstrap_Servers)
-	configuration.Kafka.Sasl_User = viper.GetString(configuration.Kafka.Sasl_User)
-	configuration.Kafka.Sasl_Password = viper.GetString(configuration.Kafka.Sasl_Password)
+	// configuration.Kafka.Sasl_User = viper.GetString(configuration.Kafka.Sasl_User)
+	// configuration.Kafka.Sasl_Password = viper.GetString(configuration.Kafka.Sasl_Password)
 	configuration.SchemaRegistry.Endpoint = viper.GetString(configuration.SchemaRegistry.Endpoint)
 	configuration.SchemaRegistry.Topics = viper.GetString(configuration.SchemaRegistry.Topics)
 	configuration.Kafka.Kafka_Topic_Json = viper.GetString(configuration.Kafka.Kafka_Topic_Json)