tencent cloud

   // 客户端配置信息
   ClientConfiguration config;
   // 设置授权角色密钥
   AuthenticationPtr auth = pulsar::AuthToken::createWithToken(AUTHENTICATION);
   config.setAuth(auth);
   // 创建客户端
   Client client(SERVICE_URL, config);


// 生产者配置
ProducerConfiguration producerConf;
producerConf.setBlockIfQueueFull(true);
producerConf.setSendTimeout(5000);
// 生产者
Producer producer;
// 创建生产者
Result result = client.createProducer(
    // topic完整路径，格式为persistent://集群（租户）ID/命名空间/Topic名称
    "persistent://pulsar-xxx/sdk_cpp/topic1",
    producerConf,
    producer);
if (result != ResultOk) {
    std::cout << "Error creating producer: " << result << std::endl;
    return -1;
}


   // 消息内容
   std::string content = "hello cpp client, this is a msg";
   // 构建消息对象
   Message msg = MessageBuilder().setContent(content)
       .setPartitionKey("mykey")  // 业务key
       .setProperty("x", "1")   // 设置消息参数
       .build();
   // 发送消息
   Result result = producer.send(msg);
   if (result != ResultOk) {
       // 发送失败
       std::cout << "The message " << content << " could not be sent, received code: " << result << std::endl;
   } else {
       // 发送成功
       std::cout << "The message " << content << " sent successfully" << std::endl;
   }


   // 消费者配置信息
   ConsumerConfiguration consumerConfiguration;
   consumerConfiguration.setSubscriptionInitialPosition(pulsar::InitialPositionEarliest);
   // 消费者
   Consumer consumer;
   // 订阅topic
   Result result = client.subscribe(
       // topic完整路径，格式为persistent://集群（租户）ID/命名空间/Topic名称
       "persistent://pulsar-xxx/sdk_cpp/topic1",
       // 订阅名称
       "sub_topic1",
       consumerConfiguration,
       consumer);

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


   Message msg;
   // 获取消息
   consumer.receive(msg);
   // 模拟业务
   std::cout << "Received: " << msg << "  with payload '" << msg.getDataAsString() << "'" << std::endl;
   // 回复ack
   consumer.acknowledge(msg);
   // 消费失败回复nack, 消息将会重新投递
   // consumer.negativeAcknowledge(msg);