Merge pull request #62 from ialeksandrov/fix-connection-helper

Fixing really annoying bug.
redpanda-data · Sep 18, 2020 · 170c252 · 170c252
2 parents 03d8c6d + 58db050
commit 170c252
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/connection_helper.go b/kafka/connection_helper.go
@@ -76,7 +76,7 @@ func saramaClientConfig(opts *options.Options) *sarama.Config {
 		case sarama.SASLTypeGSSAPI:
 			clientConfig.Net.SASL.Mechanism = sarama.SASLTypeGSSAPI
 			switch opts.SASLGSSAPIAuthType {
-			case "USER_AUTH:":
+			case "USER_AUTH":
 				clientConfig.Net.SASL.GSSAPI.AuthType = sarama.KRB5_USER_AUTH
 			case "KEYTAB_AUTH":
 				clientConfig.Net.SASL.GSSAPI.AuthType = sarama.KRB5_KEYTAB_AUTH