Merge pull request #13 from medici/prometheus-integration
DE-474 config changes
This commit is contained in:
4
main.go
4
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)
|
||||
|
||||
Reference in New Issue
Block a user