create_and_close_pulsar_client.cc

#include <iostream>
#include <pulsar/Client.h>

using namespace std;
using namespace pulsar;

int main() {
    for (int i = 0; i < 100; i++) {
        Client client("pulsar://localhost:6650");

        Producer producer;
        Result result = client.createProducer("persistent://public/default/test", producer);

        if (result != ResultOk) {
            cerr << "Failed to create producer: " << result << endl;
            return -1;
        }

        Message msg = MessageBuilder().setContent("my-message").build();
        Result res = producer.send(msg);

        if (res == ResultOk) {
            cout << "Send: " << msg.getDataAsString() << endl;
        } else {
            cerr << "Failed to send message: " << res << endl;
        }

        producer.close();
        client.close();
    }
}