KAFKA 提交问题

Question

我是 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'的未定义引用

请帮助我如何进一步进行。

Answer 1

如果你想使用Kafka Producer的事务管理那么你必须

• 首先使用方法

  rd_kafka_init_transactions()

  在这里在您的生产者
  上启动新交易

• 然后你必须打电话给

  rd_kafka_begin_transaction()

  这里.

• 之后产生消息

• 最后一步应该是使用

  rd_kafka_commit_transaction()

  提交交易。

希望对您有所帮助！