This is an automated email from the ASF dual-hosted git repository. zhaocong pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit fb950f64c1917c2320f471a032824b9365a31f18 Author: Matteo Merli <[email protected]> AuthorDate: Thu Mar 12 12:33:07 2026 -0700 [fix] Fix flaky OneWayReplicatorTest.testTopicPoliciesReplicationRule (#25316) --- .../java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java index 8a80f57f5b2..aa9b7053719 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java @@ -1685,8 +1685,7 @@ public class OneWayReplicatorTest extends OneWayReplicatorTestBase { producer1.close(); assertTrue(pulsar2.getPulsarResources().getTopicResources().persistentTopicExists(topicNameObj).join()); admin1.topics().createSubscription(topicName, subscriptionName, MessageId.earliest); - admin1.topics().createSubscription(subscriptionName, topicName, MessageId.earliest); - admin2.topics().createSubscription(subscriptionName, topicName, MessageId.earliest); + admin2.topics().createSubscription(topicName, subscriptionName, MessageId.earliest); // Case 1: Global topic level policies -> Add: replicate. PublishRate publishRateAddGlobal = new PublishRate(100, 10000);
