MINOR: Wait for embedded clusters to start before using them in Conne…

…ct OffsetsApiIntegrationTest (apache#16286)

Reviewers: Greg Harris <[email protected]>

connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java

@@ -143,6 +143,15 @@ private static EmbeddedConnectCluster createOrReuseConnectWithWorkerProps(Map<St
 
             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;
         });
     }