我是Kafka代理的新手，根据要求，生产者必须提交消息。（使用librdkafka c/c++库）
因此，首先在我的producer. c中，我使用rd_Kafka_commit（rk，NULL，0），但我得到以下错误RD_KAFKA_RESP_ERR__UNKNOWN_GROUP = -179（未知客户端组）
现在我在producer. c中使用这个方法rd_Kafka_commit_transaction（），但是得到了下面的编译错误。
未定义对“rd_Kafka_init_transactions”的引用
请帮助我如何继续。
1条答案
按热度按时间c0vxltue1#
如果你想使用Kafka Producer的事务管理，那么你必须
rd_kafka_init_transactions()在生产者上启动一个新事务rd_kafka_begin_transaction()。rd_kafka_commit_transaction()提交事务。希望这能有所帮助!