Merge pull request #292 from k-wall/enable-sasl-v1

feat: Allow SASL handshake version to be influenced from config

Author: birdayz

cmd/kaf/kaf.go

@@ -40,6 +40,7 @@ func getConfig() (saramaConfig *sarama.Config) {
 			saramaConfig.Net.SASL.User = cluster.SASL.Username
 			saramaConfig.Net.SASL.Password = cluster.SASL.Password
 		}
+		saramaConfig.Net.SASL.Version = cluster.SASL.Version
 	}
 	if cluster.TLS != nil && cluster.SecurityProtocol != "SASL_SSL" {
 		saramaConfig.Net.TLS.Enable = true

examples/sasl_v1_handshake.yaml

@@ -0,0 +1,9 @@
+clusters:
+- name: test
+  brokers:
+  - localhost:9092
+  SASL:
+    mechanism: PLAIN
+    username: admin
+    password: mypasswordisnotsosimple
+    version: 1

pkg/config/config.go

@@ -17,6 +17,7 @@ type SASL struct {
 	ClientSecret string `yaml:"clientSecret"`
 	TokenURL     string `yaml:"tokenURL"`
 	Token        string `yaml:"token"`
+	Version      int16  `yaml:"version"`
 }
 
 type TLS struct {