(pulsar) branch master updated: [fix] Fix flaky OneWayReplicatorTest.testTopicPoliciesReplicationRule (#25316)

[lh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 0495c8a16e4 [fix] Fix flaky OneWayReplicatorTest.testTopicPoliciesReplicationRule (#25316)
0495c8a16e4 is described below

commit 0495c8a16e4ed30e8047fd1541dc63dc62dc29a7
Author: Matteo Merli <mm...@apache.org>
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 aa3c2b77bc5..195b2841373 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
@@ -1693,8 +1693,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);