From 73b93287eba30ea9f90b6c89189bc88b8370a3ed Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E2=80=9Cnishant-sharma=E2=80=9D?= Date: Thu, 6 May 2021 15:44:12 +0530 Subject: [PATCH] removing auth vars --- main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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)