You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2024/11/28 02:59:27 UTC
(kafka) branch trunk updated: KAFKA-18109 Fix failed SaslClientsWithInvalidCredentialsTest in tools module (#17971)
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 <tj...@gmail.com>
AuthorDate: Thu Nov 28 10:59:21 2024 +0800
KAFKA-18109 Fix failed SaslClientsWithInvalidCredentialsTest in tools module (#17971)
Reviewers: Chia-Ping Tsai <ch...@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(