diff --git a/pkg/kafka/auth/config.go b/pkg/kafka/auth/config.go index d2e026d43fd..89ba37bf07b 100644 --- a/pkg/kafka/auth/config.go +++ b/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,