fix(sasl): fix sasl configs (#2096)

Signed-off-by: Ning Yu <ningyu@automq.com>
AutoMQ · Oct 29, 2024 · 047560c · 047560c
1 parent 3eedc14
commit 047560c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java b/clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java
@@ -320,7 +320,8 @@ private void createServerCallbackHandlers(Map<String, ?> configs) {
             AuthenticateCallbackHandler callbackHandler;
             String prefix = ListenerName.saslMechanismPrefix(mechanism);
             @SuppressWarnings("unchecked")
-            Class<? extends AuthenticateCallbackHandler> clazz = (Class<? extends AuthenticateCallbackHandler>) configs.get(SaslConfigs.SASL_CLIENT_CALLBACK_HANDLER_CLASS);
+            Class<? extends AuthenticateCallbackHandler> clazz =
+                (Class<? extends AuthenticateCallbackHandler>) configs.get(prefix + BrokerSecurityConfigs.SASL_SERVER_CALLBACK_HANDLER_CLASS_CONFIG);
             // AutoMQ inject start
             if (clazz != null) {
                 if (Utils.hasConstructor(clazz, SaslChannelBuilder.class)) {