setAdvertisedAddress

datastax · Apr 8, 2024 · 9c1db29 · 9c1db29
1 parent bc3b3e5
commit 9c1db29
Showing 1 changed file with 11 additions and 4 deletions.
diff --git a/pulsar-jms/src/test/java/com/datastax/oss/pulsar/jms/utils/PulsarCluster.java b/pulsar-jms/src/test/java/com/datastax/oss/pulsar/jms/utils/PulsarCluster.java
@@ -42,6 +42,9 @@ public PulsarCluster(Path tempDir, Consumer<ServiceConfiguration> configurationC
     ServiceConfiguration config = new ServiceConfiguration();
     config.setZookeeperServers(bookKeeperCluster.getZooKeeperAddress());
     config.setClusterName("localhost");
+    config.setAdvertisedAddress("localhost");
+    config.setBrokerShutdownTimeoutMs(0L);
+    config.setLoadBalancerOverrideBrokerNicSpeedGbps(Optional.of(1.0d));
     config.setManagedLedgerDefaultEnsembleSize(1);
     config.setManagedLedgerDefaultWriteQuorum(1);
     config.setManagedLedgerDefaultAckQuorum(1);
@@ -77,10 +80,14 @@ public void start() throws Exception {
     bookKeeperCluster.startBookie();
     service.start();
 
-    service.getAdminClient().clusters().createCluster("localhost", ClusterData.builder()
-            .serviceUrl(getAddress())
-            .brokerServiceUrl(service.getBrokerServiceUrl())
-            .build());
+    service
+        .getAdminClient()
+        .clusters()
+        .createCluster(
+            "localhost",
+            ClusterData.builder()
+                .brokerServiceUrl(service.getBrokerServiceUrl())
+                .build());
     service
         .getAdminClient()
         .tenants()