add wait on ISR

apache · Sep 6, 2024 · 2af2478 · 2af2478
1 parent 0358527
commit 2af2478
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala b/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala
@@ -308,7 +308,9 @@ class ZkMigrationIntegrationTest {
           false
         } else {
           topicDescribe.topicNameValues().values().stream().allMatch {
-            topic => topic.get(32, TimeUnit.SECONDS).partitions().stream().allMatch(part => part.leader() != null)
+            topic => topic.get(62, TimeUnit.SECONDS).partitions().stream().allMatch(part => {
+              part.leader() != null && part.isr().size() == 3
+            })
           }
         }
       }, msg="waiting for topics to be available", waitTimeMs=303000)