Support SASL mechanisms with SASL_PLAINTEXT

urusha · web-flow · commit 9f7403c03c35 · 2022-08-09T12:30:42.000+03:00
Allow using SASL mechanisms other than PLAIN with SASL_PLAINTEXT security protocol
diff --git a/cmd/kaf/kaf.go b/cmd/kaf/kaf.go
@@ -99,6 +99,8 @@ func getConfig() (saramaConfig *sarama.Config) {
 		} else {
 			saramaConfig.Net.TLS.Config = &tls.Config{InsecureSkipVerify: false}
 		}
+	}
+	if cluster.SecurityProtocol == "SASL_SSL" || cluster.SecurityProtocol == "SASL_PLAINTEXT" {
 		if cluster.SASL.Mechanism == "SCRAM-SHA-512" {
 			saramaConfig.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: SHA512} }
 			saramaConfig.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512)

Original file line number	Diff line number	Diff line change
`@@ -99,6 +99,8 @@ func getConfig() (saramaConfig *sarama.Config) {`
`99`	`99`	`} else {`
`100`	`100`	`saramaConfig.Net.TLS.Config = &tls.Config{InsecureSkipVerify: false}`
`101`	`101`	`}`
	`102`	`+ }`
	`103`	`+ if cluster.SecurityProtocol == "SASL_SSL" \|\| cluster.SecurityProtocol == "SASL_PLAINTEXT" {`
`102`	`104`	`if cluster.SASL.Mechanism == "SCRAM-SHA-512" {`
`103`	`105`	`saramaConfig.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: SHA512} }`
`104`	`106`	`saramaConfig.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512)`