Fix Flaky test BacklogQuotaManagerTest.testConsumerBacklogEvictionTim…

…eQuotaWithEmptyLedger (#13724) (cherry picked from commit 1fd4490)
apache · Jan 18, 2022 · f3bf499 · f3bf499
1 parent 2e78d93
commit f3bf499
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
@@ -504,6 +504,7 @@ public void testConsumerBacklogEvictionTimeQuotaWithEmptyLedger() throws Excepti
         consumer.receive();
 
         admin.topics().unload(topic);
+        Awaitility.await().until(consumer::isConnected);
         PersistentTopicInternalStats internalStats = admin.topics().getInternalStats(topic);
         assertEquals(internalStats.ledgers.size(), 2);
         assertEquals(internalStats.ledgers.get(1).entries, 0);