使用librdkafka实现Producer消息提交遇错求助

第一个错误：RD_KAFKA_RESP_ERR__UNKNOWN_GROUP (-179) #

• rd_kafka_commit() 是消费者专属API，用于提交消费者的位移（offset），生产者根本不需要调用这个方法。
• 生产者的消息提交（确保消息被Broker持久化）通过配置参数 acks 控制：
  • 设置 acks=1：Leader节点确认接收后返回成功
  • 设置 acks=all（或 -1）：所有同步副本确认接收后返回成功
  • 只需在创建生产者时配置好 acks，调用 rd_kafka_produce() 发送消息，再通过回调或轮询确认发送结果即可，完全不需要调用 rd_kafka_commit()

第二个错误：undefined reference to rd_kafka_init_transactions #

这个编译错误通常由以下原因导致，逐一排查：

1. librdkafka版本过低：事务相关API（包括 rd_kafka_init_transactions、rd_kafka_commit_transaction）是在librdkafka 0.11.0版本之后才引入的，若你的版本低于此，升级到最新稳定版即可。
2. 编译时未正确链接librdkafka库：编译producer.c时，必须在命令行末尾加上链接参数 -lrdkafka，如果库不在默认路径，还要用 -L 指定库路径。示例命令：

   gcc producer.c -o producer -lrdkafka
   

3. 静态库链接缺失依赖：如果使用静态库编译，可能需要额外链接依赖库（如 pthread、ssl、crypto 等），完整编译命令类似：

   gcc producer.c -o producer /path/to/librdkafka.a -lpthread -lssl -lcrypto -lz
   

额外说明：只有当你需要实现Exactly-Once语义的事务型生产者时，才需要调用事务相关API。如果只是普通的消息提交（确保Broker接收消息），用 acks 参数配置就足够，无需启用事务。

内容的提问来源于stack exchange，提问作者Nishtha Yadav