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
index c5103bff5d5b6..14e92c6789484 100644
--- 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
@@ -521,7 +521,7 @@ public void testClusterMigrationWithReplicationBacklog() throws Exception {
         pulsar3 = broker3.getPulsarService();
 
         // verify that the replication backlog drains once service in cluster "r3" is restarted.
-        retryStrategically((test) -> !topic1.isReplicationBacklogExist(), 10, 1000);
+        retryStrategically((test) -> !topic1.isReplicationBacklogExist(), 30, 1000);
         assertFalse(topic1.isReplicationBacklogExist());
 
         // verify that the producer1 is now connected to migrated cluster "r2" since backlog is cleared.