test: retry shouldListTopics test (#8244)

confluentinc · Oct 12, 2021 · 7c7ac07 · 7c7ac07
1 parent 60c1bb2
commit 7c7ac07
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/...-client/src/test/java/io/confluent/ksql/api/client/integration/ClientIntegrationTest.java b/...-client/src/test/java/io/confluent/ksql/api/client/integration/ClientIntegrationTest.java
@@ -797,11 +797,14 @@ public void shouldListTables() throws Exception {
   @SuppressWarnings("unchecked")
   @Test
   public void shouldListTopics() throws Exception {
-    // When
-    final List<TopicInfo> topics = client.listTopics().get();
-
-    // Then
-    assertThat("" + topics, topics, containsInAnyOrder(
+    // Then:
+    assertThatEventually(() -> {
+      try {
+        return client.listTopics().get();
+      } catch (final InterruptedException | ExecutionException e) {
+        return null;
+      }
+    }, containsInAnyOrder(
         topicInfo(TEST_TOPIC),
         topicInfo(EMPTY_TEST_TOPIC),
         topicInfo(AGG_TABLE),