(kafka) branch trunk updated: KAFKA-18109 Fix failed SaslClientsWithInvalidCredentialsTest in tools module (#17971)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new e1ba01d2144 KAFKA-18109 Fix failed 
SaslClientsWithInvalidCredentialsTest in tools module (#17971)
e1ba01d2144 is described below

commit e1ba01d21440a1de011c116a0bb6933656200009
Author: TaiJuWu <tjwu1...@gmail.com>
AuthorDate: Thu Nov 28 10:59:21 2024 +0800

    KAFKA-18109 Fix failed SaslClientsWithInvalidCredentialsTest in tools 
module (#17971)
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/tools/src/test/java/org/apache/kafka/tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java
 
b/tools/src/test/java/org/apache/kafka/tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java
index 86f41a72972..3895f23c88d 100644
--- 
a/tools/src/test/java/org/apache/kafka/tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java
+++ 
b/tools/src/test/java/org/apache/kafka/tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java
@@ -23,6 +23,7 @@ import kafka.security.JaasTestUtils;
 import org.apache.kafka.clients.admin.Admin;
 import org.apache.kafka.clients.admin.NewTopic;
 import org.apache.kafka.clients.consumer.Consumer;
+import org.apache.kafka.common.config.SaslConfigs;
 import org.apache.kafka.common.errors.SaslAuthenticationException;
 import org.apache.kafka.common.security.auth.SecurityProtocol;
 import org.apache.kafka.common.serialization.ByteArrayDeserializer;
@@ -114,6 +115,8 @@ public class SaslClientsWithInvalidCredentialsTest extends 
AbstractSaslTest {
     public void setUp(TestInfo testInfo) {
         startSasl(jaasSections(KAFKA_SERVER_SASL_MECHANISMS, 
Some$.MODULE$.apply(KAFKA_CLIENT_SASL_MECHANISM), Both$.MODULE$,
             JaasTestUtils.KAFKA_SERVER_CONTEXT_NAME));
+        String superuserLoginContext = 
jaasAdminLoginModule(KAFKA_CLIENT_SASL_MECHANISM, Option.empty());
+        this.superuserClientConfig().put(SaslConfigs.SASL_JAAS_CONFIG, 
superuserLoginContext);
         super.setUp(testInfo);
         try (Admin admin = createPrivilegedAdminClient()) {
             admin.createTopics(Collections.singletonList(