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();