Kafka生产者使用librdkafka时结构作为输入而不是字符串的问题

1. 定义一个结构体，其中包含需要发送到Kafka的所有字段。

typedef struct {
    int id;
    char name[64];
    double price;
} product;

2. 配置Kafka生产者的属性。

rd_kafka_conf_t *conf = rd_kafka_conf_new();
...

3. 创建Kafka生产者实例。

rd_kafka_t *producer = rd_kafka_new(RD_KAFKA_PRODUCER, conf, errstr, sizeof(errstr));
...

4. 使用rd_kafka_produce函数向Kafka发送消息。

// 构造product对象
product p = {1, "product1", 10.0};
// 构造生产消息对象
rd_kafka_message_t *msg = rd_kafka_message_new();
// 将product对象转换为字符数组
char *payload = (char *) &p;
// 设置消息的负载和长度
rd_kafka_message_payload_set(msg, payload, sizeof(product));
// 发送消息
rd_kafka_produce(producer, topic, partition, RD_KAFKA_MSG_F_COPY, msg, NULL);
// 释放资源
rd_kafka_message_destroy(msg);

通过这种方式，我们可以将结构体作为输入发送到Kafka生产者，而不是字符串。