From c05e998a5220ff9d0ddc3c3fc36f058bd50b0d27 Mon Sep 17 00:00:00 2001
From: fengyubiao <yubiao.feng@streamnative.io>
Date: Tue, 25 Feb 2025 14:49:33 +0800
Subject: [PATCH] [fix][test] Fix flaky test
 OneWayReplicatorUsingGlobalZKTest.testConfigReplicationStartAt (#24011)

(cherry picked from commit 8b196d8abfa1f5e4ac71bea7c08cafa35d04bae2)
---
 .../broker/service/OneWayReplicatorUsingGlobalZKTest.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
index ef29376368cac..f7738c2207bf2 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
@@ -156,6 +156,10 @@ public void testConfigReplicationStartAt() throws Exception {
         p1.close();
 
         admin1.namespaces().setNamespaceReplicationClusters(ns1, new HashSet<>(Arrays.asList(cluster1, cluster2)));
+        Awaitility.await().untilAsserted(() -> {
+            assertTrue(admin2.topics().getList(ns1).contains(topic1));
+        });
+        admin2.topics().createSubscription(topic1, subscription1, MessageId.earliest);
         org.apache.pulsar.client.api.Consumer<String> c1 = client2.newConsumer(Schema.STRING).topic(topic1)
                 .subscriptionName(subscription1).subscribe();
         Message<String> msg2 = c1.receive(2, TimeUnit.SECONDS);