Allow unconfigured SASL

2026-08-09 04:36:05 +10:00 · 2019-07-25 16:19:09 -07:00
parent 4f34b08830
commit dd43774263
1 changed files with 3 additions and 0 deletions
@@ -27,6 +27,9 @@ type SaramaSASL struct {
 func (c *SASLConfig) SetSaramaSASLConfig(config *sarama.Config) error {
 	sasl := config.Net.SASL
 	switch c.SASLMechanism {
+	case "":
+		// SASL is not enabled
+		return nil
 	case "PLAIN":
 		sasl.Mechanism = sarama.SASLTypePlaintext
 	case "SCRAM-SHA-256":