The Pulsar C++ client

Supported platforms

The Pulsar C++ client has been successfully tested on MacOS and Linux.

Linux

Install

Since the 2.1.0 release, Pulsar ships pre-built RPM and Debian packages. You can choose to downloadand install those packages instead of building them yourself.

RPM

To install a RPM package, download the RPM packages and install them using the following command:

$ rpm -ivh apache-pulsar-client*.rpm

DEB

To install a DEB package, download the DEB packages and install them using the following command:

$ apt install ./apache-pulsar-client*.deb

Build

If you want to build RPM and Debian packages off latest master, you can follow the instructionsbelow to do so. All the instructions are run at the root directory of your cloned Pulsarrepo.

There are recipes that build RPM and Debian packages containing astatically linked libpulsar.so / libpulsar.a with all the requireddependencies.

To build the C++ library packages, first build the Java packages:

mvn install -DskipTests

RPM

pulsar-client-cpp/pkg/rpm/docker-build-rpm.sh

This will build the RPM inside a Docker container and it will leave the RPMsin pulsar-client-cpp/pkg/rpm/RPMS/x86_64/.

Deb

To build Debian packages:

pulsar-client-cpp/pkg/deb/docker-build-deb.sh

Debian packages will be created at pulsar-client-cpp/pkg/deb/BUILD/DEB/

MacOS

Pulsar releases are available through the Homebrew core repository. You can install the C++ clientlibrary with:

brew install libpulsar

This will install the package with the library and headers.

Connection URLs

To connect to Pulsar using client libraries, you need to specify a Pulsar protocol URL.

Pulsar protocol URLs are assigned to specific clusters, use the pulsar URI scheme and have a default port of 6650. Here’s an example for localhost:

pulsar://localhost:6650

A URL for a production Pulsar cluster may look something like this:

pulsar://pulsar.us-west.example.com:6650

If you’re using TLS authentication, the URL will look like something like this:

pulsar+ssl://pulsar.us-west.example.com:6651

Consumer

Client client("pulsar://localhost:6650");
Consumer consumer;
Result result = client.subscribe("my-topic", "my-subscribtion-name", consumer);
if (result != ResultOk) {
    LOG_ERROR("Failed to subscribe: " << result);
    return -1;
}
Message msg;
while (true) {
    consumer.receive(msg);
    LOG_INFO("Received: " << msg
            << "  with payload '" << msg.getDataAsString() << "'");
    consumer.acknowledge(msg);
}
client.close();

Producer

Client client("pulsar://localhost:6650");
Producer producer;
Result result = client.createProducer("my-topic", producer);
if (result != ResultOk) {
    LOG_ERROR("Error creating producer: " << result);
    return -1;
}
// Publish 10 messages to the topic
for (int i = 0; i < 10; i++){
    Message msg = MessageBuilder().setContent("my-message").build();
    Result res = producer.send(msg);
    LOG_INFO("Message sent: " << res);
}
client.close();

Authentication

ClientConfiguration config = ClientConfiguration();
config.setUseTls(true);
config.setTlsTrustCertsFilePath("/path/to/cacert.pem");
config.setTlsAllowInsecureConnection(false);
config.setAuth(pulsar::AuthTls::create(
            "/path/to/client-cert.pem", "/path/to/client-key.pem"););
Client client("pulsar+ssl://my-broker.com:6651", config);