Fix Kafka TLS configuration with plaintext authentication

This change fixes the Kafka TLS configuration to work correctly when using
plaintext authentication with TLS enabled. Previously, TLS would only be
configured when authentication=tls, breaking SASL-SSL with PLAIN authentication.

Resolves jaegertracing#6744

Signed-off-by: Amol Verma <[email protected]>

Author: Amol Verma

pkg/kafka/auth/config.go

@@ -76,7 +76,6 @@ func (config *AuthenticationConfig) InitFromViper(configPrefix string, v *viper.
 	config.Kerberos.KeyTabPath = v.GetString(configPrefix + kerberosPrefix + suffixKerberosKeyTab)
 	config.Kerberos.DisablePAFXFast = v.GetBool(configPrefix + kerberosPrefix + suffixKerberosDisablePAFXFAST)
 
-	tlsEnabled := v.GetBool(configPrefix + ".tls.enabled")
 	if config.Authentication == tls || v.GetBool(configPrefix+".tls.enabled") {
 		tlsClientConfig := tlscfg.ClientFlagsConfig{
 			Prefix: configPrefix,