(pulsar) branch branch-4.1 updated: Fix compile issue

[te...@apache.org]

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

technoboy pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.1 by this push:
     new 345bed13e35 Fix compile issue
345bed13e35 is described below

commit 345bed13e3553d9fa7bcbb762e6864f5d2e47225
Author: Jiwei Guo <te...@apache.org>
AuthorDate: Thu Mar 19 18:20:31 2026 +0800

    Fix compile issue
---
 .../pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 4a3d8bbb417..4a0d2131000 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
@@ -682,7 +682,7 @@ public class OneWayReplicatorUsingGlobalZKTest extends OneWayReplicatorTest {
         Predicate<String> topicNameFilter = t -> TopicName.get(t).getNamespace().equals(ns);
         String systemTopic = "persistent://" + ns + "/__change_events";
         admin1.namespaces().createNamespace(ns);
-        admin1.namespaces().setNamespaceReplicationClusters(ns, new HashSet<>(Arrays.asList(cluster1)), false);
+        admin1.namespaces().setNamespaceReplicationClusters(ns, new HashSet<>(Arrays.asList(cluster1)));
         Awaitility.await().untilAsserted(() -> {
             assertEquals(admin1.namespaces().getNamespaceReplicationClusters(ns).size(), 1);
             assertEquals(admin2.namespaces().getNamespaceReplicationClusters(ns).size(), 1);
@@ -729,7 +729,7 @@ public class OneWayReplicatorUsingGlobalZKTest extends OneWayReplicatorTest {
         // Set topic auto-creation rule to "partitions: 2".
         final String tp = BrokerTestUtil.newUniqueName("persistent://" + ns + "/tp");
         final Set<String> clusters = new HashSet<>(Arrays.asList(cluster1, cluster2));
-        admin1.namespaces().setNamespaceReplicationClusters(ns, clusters, true);
+        admin1.namespaces().setNamespaceReplicationClusters(ns, clusters);
         AutoTopicCreationOverride autoTopicCreation2 =
                 AutoTopicCreationOverrideImpl.builder().allowAutoTopicCreation(true)
                         .topicType("partitioned").defaultNumPartitions(2).build();