[fix][pulsar-broker] Fix flaky testcase - testClusterMigrationWithRep…

…licationBacklog
apache · Jun 8, 2023 · 75a377f · 75a377f
1 parent 362ece3
commit 75a377f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ClusterMigrationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ClusterMigrationTest.java
@@ -458,8 +458,8 @@ public void testClusterMigrationWithReplicationBacklog(boolean persistent, Subsc
         retryStrategically((test) -> !topic1.isReplicationBacklogExist(), 10, 1000);
         assertFalse(topic1.isReplicationBacklogExist());
 
-        producer1.send("test".getBytes());
         // verify that the producer1 is now connected to migrated cluster "r2" since backlog is cleared.
+        retryStrategically((test) -> topic2.getProducers().size() == 2, 60, 1000);
         assertEquals(topic2.getProducers().size(), 2);
     }