From d486a79bc11ee242da2c7fa6e021a7922a45d3ed Mon Sep 17 00:00:00 2001 From: Nitin Date: Tue, 27 Jul 2021 11:12:30 +0530 Subject: [PATCH] DE-121 added config --- .gitignore | 1 + main.go | 4 ++-- producer/producer_config.go | 20 ++++++++++---------- 3 files changed, 13 insertions(+), 12 deletions(-) create mode 100644 .gitignore diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..485dee6 --- /dev/null +++ b/.gitignore @@ -0,0 +1 @@ +.idea diff --git a/main.go b/main.go index a0386b1..3e7c756 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) diff --git a/producer/producer_config.go b/producer/producer_config.go index 65201e7..d075a47 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -21,11 +21,11 @@ func GetSyncProducerConfig(kafkaConfiguration config.KafkaConfigurations) *saram // security configs // config.Net.TLS.Enable = true - // config.Net.SASL.Enable = true - // config.Net.SASL.Handshake = true - // config.Net.SASL.Mechanism = sarama.SASLTypePlaintext - // config.Net.SASL.User = kafkaConfiguration.Sasl_User - // config.Net.SASL.Password = kafkaConfiguration.Sasl_Password + config.Net.SASL.Enable = true + config.Net.SASL.Handshake = true + config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512 + config.Net.SASL.User = kafkaConfiguration.Sasl_User + config.Net.SASL.Password = kafkaConfiguration.Sasl_Password // producer configs // to be changed: read from config file @@ -46,11 +46,11 @@ func GetAsyncProducerConfig(kafkaConfiguration config.KafkaConfigurations) *sara // security configs // config.Net.TLS.Enable = true - // config.Net.SASL.Enable = true - // config.Net.SASL.Handshake = true - // config.Net.SASL.Mechanism = sarama.SASLTypePlaintext - // config.Net.SASL.User = kafkaConfiguration.Sasl_User - // config.Net.SASL.Password = kafkaConfiguration.Sasl_Password + config.Net.SASL.Enable = true + config.Net.SASL.Handshake = true + config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512 + config.Net.SASL.User = kafkaConfiguration.Sasl_User + config.Net.SASL.Password = kafkaConfiguration.Sasl_Password // producer configs // to be changed: read from config file