diff --git a/main.go b/main.go
index 008e91c..e2f5a01 100644
--- a/main.go
+++ b/main.go
@@ -35,7 +35,7 @@ func init() {
 	}
 	//log.Print(configuration.Kafka.Bootstrap_Servers)
 	// Following coinfigurations read from environment variables
-	/* configuration.Env = viper.GetString(configuration.Env)
+	configuration.Env = viper.GetString(configuration.Env)
 	configuration.Kafka.Bootstrap_Servers = viper.GetString(configuration.Kafka.Bootstrap_Servers)
 	configuration.SchemaRegistry.Endpoint = viper.GetString(configuration.SchemaRegistry.Endpoint)
 	configuration.SchemaRegistry.Topics = viper.GetString(configuration.SchemaRegistry.Topics)
@@ -46,7 +46,7 @@ func init() {
     //if configuration.Env == "PROD" {
         configuration.Kafka.Sasl_User = viper.GetString(configuration.Kafka.Sasl_User)
         configuration.Kafka.Sasl_Password = viper.GetString(configuration.Kafka.Sasl_Password)
-    //} */
+    //} 
 	
 	port = configuration.Server.Port
 	log.Printf("PORT IS: %v", port)