(kafka) branch trunk updated: KAFKA-18441: Fix flaky KafkaAdminClientTest#testAdminClientApisAuthenticationFailure (#18735)

[schofielaj]

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

schofielaj 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 0dfc4017b85 KAFKA-18441: Fix flaky 
KafkaAdminClientTest#testAdminClientApisAuthenticationFailure (#18735)
0dfc4017b85 is described below

commit 0dfc4017b85a4e908662672c412bafcf1d13ad52
Author: PoAn Yang <pay...@apache.org>
AuthorDate: Thu Jan 30 16:01:20 2025 +0800

    KAFKA-18441: Fix flaky 
KafkaAdminClientTest#testAdminClientApisAuthenticationFailure (#18735)
    
    Reviewers: Lianet Magrans <lmagr...@confluent.io>, Chia-Ping Tsai 
<chia7...@gmail.com>, Andrew Schofield <aschofi...@confluent.io>
---
 .../java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
 
b/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
index 25cd12752c1..07b4b55e268 100644
--- 
a/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
+++ 
b/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
@@ -1788,7 +1788,10 @@ public class KafkaAdminClientTest {
     public void testAdminClientApisAuthenticationFailure() {
         Cluster cluster = mockBootstrapCluster();
         try (final AdminClientUnitTestEnv env = new 
AdminClientUnitTestEnv(Time.SYSTEM, cluster,
-                newStrMap(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, 
"1000"))) {
+                newStrMap(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, "1000",
+                    // Default "metadata.recovery.strategy" is rebootstrap. If 
it meets "retry.backoff.ms" (default is 100L),
+                    // following assertion will fail. Set it to none to avoid 
authentication error cleanup.
+                    AdminClientConfig.METADATA_RECOVERY_STRATEGY_CONFIG, 
"none"))) {
             env.kafkaClient().setNodeApiVersions(NodeApiVersions.create());
             
env.kafkaClient().createPendingAuthenticationError(cluster.nodes().get(0),
                     TimeUnit.DAYS.toMillis(1));