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 uses memory limits param to control client overall memory usage, the producers and consumers under this client will compete for the memory assigned. 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
})