kafka c++ client 库

Kafka C++ Client 库是 Apache Kafka 官方提供的 C++ 客户端库，可以让 C++ 开发者使用 Kafka 的消息传递机制，实现高效、可靠的消息传递。下面是 Kafka C++ Client 库的使用方法：

1. 下载 Kafka C++ Client 库：从 Apache Kafka 官网下载 Kafka C++ Client 库的源代码。

2. 编译 Kafka C++ Client 库：使用 cmake 工具编译 Kafka C++ Client 库的源代码，生成可执行文件或库文件。

3. 配置 Kafka C++ Client 库：在 C++ 项目中，引入 Kafka C++ Client 库的头文件和库文件，配置链接选项。

4. 编写 C++ 代码：使用 Kafka C++ Client 库的 API，编写 C++ 代码实现 Kafka 生产者和消费者的功能。

下面是一个简单的 Kafka 生产者 C++ 代码示例：

#include <librdkafka/rdkafkacpp.h>
#include <iostream>

int main() {
    std::string brokers = "localhost:9092";
    std::string topic_name = "test";
    std::string errstr;

    RdKafka::Producer *producer = RdKafka::Producer::create({
            {"bootstrap.servers", brokers}
    }, errstr);

    if (!producer) {
        std::cerr << "Failed to create producer: " << errstr << std::endl;
        return -1;
    }

    RdKafka::Topic *topic = RdKafka::Topic::create(producer, topic_name, nullptr, errstr);

    if (!topic) {
        std::cerr << "Failed to create topic: " << errstr << std::endl;
        delete producer;
        return -1;
    }

    std::string message = "Hello, Kafka!";
    RdKafka::ErrorCode resp = producer->produce(topic, RdKafka::Topic::PARTITION_UA, RdKafka::Producer::RK_MSG_COPY, const_cast<char *>(message.c_str()), message.size(), nullptr, nullptr);

    if (resp != RdKafka::ErrorCode::ERR_NO_ERROR) {
        std::cerr << "Failed to produce message: " << RdKafka::err2str(resp) << std::endl;
    }

    producer->flush(1000);

    delete topic;
    delete producer;

    return 0;
}

需要注意的是，Kafka C++ Client 库的使用方法有很多种，具体使用方法需要根据项目需求和库的版本进行调整。