From 9de329de4c196b30b38ebcbd6c50f0ce94e40305 Mon Sep 17 00:00:00 2001 From: Nitin Date: Tue, 27 Jul 2021 15:25:54 +0530 Subject: [PATCH] DE-121 - added scram --- producer/producer_config.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/producer/producer_config.go b/producer/producer_config.go index d39526d..7227bd7 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -24,10 +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.SASLMechanism(sarama.SASLTypeSCRAMSHA512) - config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { - return &scramclient.XDGSCRAMClient{HashGeneratorFcn: scramclient.SHA512} - } + config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512 + /* saramaConfig.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { + return &XDGSCRAMClient{HashGeneratorFcn: SHA512} + } */ config.Net.SASL.User = kafkaConfiguration.Sasl_User config.Net.SASL.Password = kafkaConfiguration.Sasl_Password } @@ -55,10 +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.SASLMechanism(sarama.SASLTypeSCRAMSHA512) - config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { - return &scramclient.XDGSCRAMClient{HashGeneratorFcn: scramclient.SHA512} - } + 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 }