(kafka) branch 3.8 updated: MINOR: Wait for embedded clusters to start before using them in Connect OffsetsApiIntegrationTest (#16286)

[cegerton]

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

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


The following commit(s) were added to refs/heads/3.8 by this push:
     new 520fbb4116b MINOR: Wait for embedded clusters to start before using 
them in Connect OffsetsApiIntegrationTest (#16286)
520fbb4116b is described below

commit 520fbb4116b92bbb362e2a67f0b20ffc644f2903
Author: Chris Egerton <chr...@aiven.io>
AuthorDate: Tue Jun 11 23:15:07 2024 +0200

    MINOR: Wait for embedded clusters to start before using them in Connect 
OffsetsApiIntegrationTest (#16286)
    
    Reviewers: Greg Harris <greg.har...@aiven.io>
---
 .../kafka/connect/integration/OffsetsApiIntegrationTest.java     | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
 
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
index dc507b68df7..2da52cf9abd 100644
--- 
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
+++ 
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
@@ -143,6 +143,15 @@ public class OffsetsApiIntegrationTest {
 
             result.start();
 
+            try {
+                result.assertions().assertExactlyNumWorkersAreUp(
+                        NUM_WORKERS,
+                        "Workers did not complete startup in time"
+                );
+            } catch (InterruptedException e) {
+                throw new RuntimeException("Interrupted while awaiting cluster 
startup", e);
+            }
+
             return result;
         });
     }