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 index 9b105ca5..b51e88e3 100644 --- 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 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()