From 80c4b8fb4934bb0dc2d0248d7952962eef95627f Mon Sep 17 00:00:00 2001 From: Nitin Date: Thu, 31 Mar 2022 16:37:54 +0530 Subject: [PATCH] DE-474 config changes --- main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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)