(kafka) branch trunk updated: MINOR: deflake AdminMetadataTest (#22968)

[lianetm]

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

lianetm 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 209ef931f22 MINOR: deflake AdminMetadataTest (#22968)
209ef931f22 is described below

commit 209ef931f22566daca3fe4f71a90550f878067ad
Author: Nikita Shupletsov <nik...@shupletsov.ca>
AuthorDate: Tue Jul 28 12:46:33 2026 -0700

    MINOR: deflake AdminMetadataTest (#22968)
    
    ClusterTest harness only waits for brokers to reach RUNNING, not for all
    of them to be registered and propagated, so a single describeCluster()
    can race with metadata propagation and see fewer brokers.   Adding a
    wait until all of them have been discovered.
    
    Reviewers: Lianet Magrans <lmagr...@confluent.io>, Chia-Ping Tsai
     <chia7...@gmail.com>
---
 .../src/test/java/org/apache/kafka/clients/admin/AdminMetadataTest.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/AdminMetadataTest.java
 
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/AdminMetadataTest.java
index e2181a1268f..856bbd8e96d 100644
--- 
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/AdminMetadataTest.java
+++ 
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/AdminMetadataTest.java
@@ -106,6 +106,7 @@ public class AdminMetadataTest {
 
     @ClusterTest
     public void testDescribeCluster() throws Exception {
+        clusterInstance.waitForReadyBrokers();
         try (Admin admin = clusterInstance.admin()) {
             DescribeClusterResult result = admin.describeCluster();
             Collection<Node> nodes = result.nodes().get();