From e1ba01d21440a1de011c116a0bb6933656200009 Mon Sep 17 00:00:00 2001 From: TaiJuWu Date: Thu, 28 Nov 2024 10:59:21 +0800 Subject: [PATCH] KAFKA-18109 Fix failed SaslClientsWithInvalidCredentialsTest in tools module (#17971) Reviewers: Chia-Ping Tsai --- .../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(