root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

KAFKA-8162: IBM JDK Class not found error when handling SASL (#6524) 

Attempt to load multiple IBM classes but fallback on loading the Sun class if the IBM one is not found.

Reviewers: Mickael Maison <mickael.maison@gmail.com>, Ismael Juma <ismael@juma.me.uk>
This commit is contained in:
Edoardo Comar 2020-01-30 17:46:03 +00:00 committed by GitHub
parent fa7047ad9a
commit d37d95b359
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosError.java
View File

@ -49,7 +49,10 @@ public enum KerberosError {
static {
try {
if (Java.isIbmJdk()) {
// different IBM JDKs versions include different security implementations
if (Java.isIbmJdk() && canLoad("com.ibm.security.krb5.KrbException")) {
KRB_EXCEPTION_CLASS = Class.forName("com.ibm.security.krb5.KrbException");
} else if (Java.isIbmJdk() && canLoad("com.ibm.security.krb5.internal.KrbException")) {
KRB_EXCEPTION_CLASS = Class.forName("com.ibm.security.krb5.internal.KrbException");
} else {
KRB_EXCEPTION_CLASS = Class.forName("sun.security.krb5.KrbException");
@ -60,6 +63,15 @@ public enum KerberosError {
}
}
private static boolean canLoad(String clazz) {
try {
Class.forName(clazz);
return true;
} catch (Exception e) {
return false;
}
}
private final int errorCode;
private final boolean retriable;