Skip to content

Commit 8f9d125

Browse files
authored
fix(sasl): fix sasl configs (#2097)
Signed-off-by: Ning Yu <[email protected]>
1 parent 81c9f99 commit 8f9d125

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,8 @@ private void createServerCallbackHandlers(Map<String, ?> configs) {
328328
AuthenticateCallbackHandler callbackHandler;
329329
String prefix = ListenerName.saslMechanismPrefix(mechanism);
330330
@SuppressWarnings("unchecked")
331-
Class<? extends AuthenticateCallbackHandler> clazz = (Class<? extends AuthenticateCallbackHandler>) configs.get(SaslConfigs.SASL_CLIENT_CALLBACK_HANDLER_CLASS);
331+
Class<? extends AuthenticateCallbackHandler> clazz =
332+
(Class<? extends AuthenticateCallbackHandler>) configs.get(prefix + BrokerSecurityConfigs.SASL_SERVER_CALLBACK_HANDLER_CLASS_CONFIG);
332333
// AutoMQ inject start
333334
if (clazz != null) {
334335
if (Utils.hasConstructor(clazz, SaslChannelBuilder.class)) {

0 commit comments

Comments
 (0)