diff --git a/kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/utils/ldap/LDAPAuthentication.java b/kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/utils/ldap/LDAPAuthentication.java index 3dbc6c99..c1694b4c 100644 --- a/kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/utils/ldap/LDAPAuthentication.java +++ b/kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/utils/ldap/LDAPAuthentication.java @@ -56,15 +56,14 @@ public class LDAPAuthentication { return null; } - private String getUserDN(String account) { - String userDN = null; - LdapContext ctx = getConnect(); + private String getUserDN(String account,LdapContext ctx) { + String userDN = ""; try { SearchControls constraints = new SearchControls(); constraints.setSearchScope(SearchControls.SUBTREE_SCOPE); NamingEnumeration en = ctx.search("", "account=" + account, constraints); if (en == null || !en.hasMoreElements()) { - return null; + return ""; } // maybe more than one element while (en.hasMoreElements()) { @@ -93,7 +92,7 @@ public class LDAPAuthentication { LdapContext ctx = getConnect(); boolean valide = false; - String userDN = getUserDN(account); + String userDN = getUserDN(account,ctx); try { assert ctx != null; ctx.addToEnvironment(Context.SECURITY_PRINCIPAL, userDN);