From 22e74377bc0f625af08486d745e1ec61b732f494 Mon Sep 17 00:00:00 2001 From: Nitin Date: Tue, 27 Jul 2021 14:47:16 +0530 Subject: [PATCH] DE-121 - added env variable --- producer/producer_config.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/producer/producer_config.go b/producer/producer_config.go index b7d4e1c..d39526d 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -24,7 +24,10 @@ func GetSyncProducerConfig(kafkaConfiguration config.KafkaConfigurations, env st if env == "PROD" { config.Net.SASL.Enable = true config.Net.SASL.Handshake = true - config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512 + config.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512) + config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { + return &scramclient.XDGSCRAMClient{HashGeneratorFcn: scramclient.SHA512} + } config.Net.SASL.User = kafkaConfiguration.Sasl_User config.Net.SASL.Password = kafkaConfiguration.Sasl_Password } @@ -52,7 +55,10 @@ func GetAsyncProducerConfig(kafkaConfiguration config.KafkaConfigurations, env s if env == "PROD" { config.Net.SASL.Enable = true config.Net.SASL.Handshake = true - config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512 + config.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512) + config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { + return &scramclient.XDGSCRAMClient{HashGeneratorFcn: scramclient.SHA512} + } config.Net.SASL.User = kafkaConfiguration.Sasl_User config.Net.SASL.Password = kafkaConfiguration.Sasl_Password }