Work with clients

After setting up your client library and creating a client object, you can explore more to start working with your client.

Create a client with multiple advertised listeners

To ensure clients in both internal and external networks can connect to a Pulsar cluster, Pulsar introduces advertisedListeners.

The following example creates a Python client using multiple advertised listeners:

Java

PulsarClient client = PulsarClient.builder()
  .serviceUrl("pulsar://xxxx:6650")
  .listenerName("external")
  .build();

C++

ClientConfiguration clientConfiguration;
clientConfiguration.setListenerName("external");
Client client("pulsar://xxxx:6650", clientConfiguration);

Python

import pulsar

client = pulsar.Client('pulsar://localhost:6650', listener_name='external')

Set memory limits

You can use memory limits parameters to control the total client memory usage, the producers and consumers under this client will compete for the memory assigned. For implementation details, see PIP 74: Pulsar client memory limits.

Java

PulsarClient client = PulsarClient.builder()
.serviceUrl("pulsar://xxxx:6650")
.memoryLimit(64, SizeUnit.MEGA_BYTES)
.build();

Go

client, err := pulsar.NewClient(pulsar.ClientOptions{
  URL: "pulsar://xxxx:6650",
  MemoryLimitBytes: 64 * 1024 * 1024, // Unit: byte
})