From 17fc7aa81ce07ee126fd8fc9464d25c7c33066eb Mon Sep 17 00:00:00 2001 From: JW Song Date: Wed, 15 Jun 2022 10:17:32 +0900 Subject: [PATCH 1/2] add supporting SASL/PLAIN --- core/internal/helpers/sarama.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go index a2af25b6..150d88b3 100644 --- a/core/internal/helpers/sarama.go +++ b/core/internal/helpers/sarama.go @@ -129,6 +129,9 @@ func GetSaramaConfigFromClientProfile(profileName string) *sarama.Config { saramaConfig.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: SHA512} } + } else if mechanism == "PLAIN" { + saramaConfig.Net.SASL.Mechanism = sarama.SASLTypePlaintext + viper.Set("sasl." + saslName + ".handshake-first", true) } saramaConfig.Net.SASL.Handshake = viper.GetBool("sasl." + saslName + ".handshake-first") saramaConfig.Net.SASL.User = viper.GetString("sasl." + saslName + ".username") From 7c68a4b54b94958349f102d8ed1ca376440217ed Mon Sep 17 00:00:00 2001 From: JW Song Date: Wed, 15 Jun 2022 11:21:51 +0900 Subject: [PATCH 2/2] fix lint --- core/internal/helpers/sarama.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go index 150d88b3..1b7e766f 100644 --- a/core/internal/helpers/sarama.go +++ b/core/internal/helpers/sarama.go @@ -131,7 +131,7 @@ func GetSaramaConfigFromClientProfile(profileName string) *sarama.Config { } } else if mechanism == "PLAIN" { saramaConfig.Net.SASL.Mechanism = sarama.SASLTypePlaintext - viper.Set("sasl." + saslName + ".handshake-first", true) + viper.Set("sasl."+saslName+".handshake-first", true) } saramaConfig.Net.SASL.Handshake = viper.GetBool("sasl." + saslName + ".handshake-first") saramaConfig.Net.SASL.User = viper.GetString("sasl." + saslName + ".username")