tencent cloud

   // Client configuration information
   ClientConfiguration config;
   // Set the role token
   AuthenticationPtr auth = pulsar::AuthToken::createWithToken(AUTHENTICATION);
   config.setAuth(auth);
   // Create a client
   Client client(SERVICE_URL, config);


// Producer configurations
ProducerConfiguration producerConf;
producerConf.setBlockIfQueueFull(true);
producerConf.setSendTimeout(5000);
// Producer
Producer producer;
// Create a producer
Result result = client.createProducer(
    // Complete path of the topic in the format of `persistent://cluster (tenant) ID/namespace/topic name`
    "persistent://pulsar-xxx/sdk_cpp/topic1",
    producerConf,
    producer);
if (result != ResultOk) {
    std::cout << "Error creating producer: " << result << std::endl;
    return -1;
}


   // Message content
   std::string content = "hello cpp client, this is a msg";
   // Create a message object
   Message msg = MessageBuilder().setContent(content)
       .setPartitionKey("mykey")  // Business key
       .setProperty("x", "1")   // Set message parameters
       .build();
   // Send the message
   Result result = producer.send(msg);
   if (result != ResultOk) {
       // The message failed to be sent
       std::cout << "The message " << content << " could not be sent, received code: " << result << std::endl;
   } else {
       // The message was successfully sent
       std::cout << "The message " << content << " sent successfully" << std::endl;
   }


   // Consumer configuration information
   ConsumerConfiguration consumerConfiguration;
   consumerConfiguration.setSubscriptionInitialPosition(pulsar::InitialPositionEarliest);
   // Consumer
   Consumer consumer;
   // Subscribe to a topic
   Result result = client.subscribe(
       // Complete path of the topic in the format of `persistent://cluster (tenant) ID/namespace/topic name`
       "persistent://pulsar-xxx/sdk_cpp/topic1",
       // Subscription name
       "sub_topic1",
       consumerConfiguration,
       consumer);

   if (result != ResultOk) {
       std::cout << "Failed to subscribe: " << result << std::endl;
       return -1;
   }


   Message msg;
   // Obtain the message
   consumer.receive(msg);
   // Simulate the business processing logic
   std::cout << "Received: " << msg << "  with payload '" << msg.getDataAsString() << "'" << std::endl;
   // Return `ack` as the acknowledgement
   consumer.acknowledge(msg);
   // Return `nack` if the consumption fails, and the message will be delivered again
   // consumer.negativeAcknowledge(msg);