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 <[email protected]>
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();

Reply via email to