Browse Source

MINOR: Update log condition in JassContext.loadServerContext (#4566)

pull/4568/head
Manikumar Reddy O 7 years ago committed by Rajini Sivaram
parent
commit
36b00300f5
  1. 2
      clients/src/main/java/org/apache/kafka/common/security/JaasContext.java

2
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java

@ -65,7 +65,7 @@ public class JaasContext { @@ -65,7 +65,7 @@ public class JaasContext {
String globalContextName = GLOBAL_CONTEXT_NAME_SERVER;
String listenerContextName = listenerName.value().toLowerCase(Locale.ROOT) + "." + GLOBAL_CONTEXT_NAME_SERVER;
Password jaasConfigArgs = (Password) configs.get(mechanism.toLowerCase(Locale.ROOT) + "." + SaslConfigs.SASL_JAAS_CONFIG);
if (jaasConfigArgs == null && configs.containsKey(SaslConfigs.SASL_JAAS_CONFIG))
if (jaasConfigArgs == null && configs.get(SaslConfigs.SASL_JAAS_CONFIG) != null)
LOG.warn("Server config {} should be prefixed with SASL mechanism name, ignoring config", SaslConfigs.SASL_JAAS_CONFIG);
return load(Type.SERVER, listenerContextName, globalContextName, jaasConfigArgs);
}

Loading…
Cancel
Save