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 }