Would be possible to support multiple brokers connection like in Pulsar Client for Java? PulsarClient client = PulsarClient.builder() .serviceUrl("pulsar://localhost:6650,localhost:6651,localhost:6652") .build(); http://pulsar.apache.org/docs/en/client-libraries-java/