This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d152559833a298b61f78b5569e7bf18877787aee Author: fengyubiao <[email protected]> AuthorDate: Tue Feb 25 14:49:33 2025 +0800 [fix][test] Fix flaky test OneWayReplicatorUsingGlobalZKTest.testConfigReplicationStartAt (#24011) (cherry picked from commit 8b196d8abfa1f5e4ac71bea7c08cafa35d04bae2) --- .../pulsar/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 9287b451c2c..a530baab9be 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 class OneWayReplicatorUsingGlobalZKTest extends OneWayReplicatorTest { 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);
