c++ - C++ kafka客户端(rdkafka)

我正在使用c++ kafka实现
C++ rdkafka 。
问题是关于RdKafka::KafkaConsumer。如何设置使用者从主题的开头开始？

附言
链接中的使用者示例基于RdKafka::Consumer，其标记为“仅旧版，请改用KafkaConsumer”

谢谢你

最佳答案

那不是“auto.offset.reset”的工作方式。仅当没有有效的提交偏移量时，“auto.offset.reset”才有效。流程如下:

启动使用者(重新启动或崩溃后)

寻找偏移量

(如果找到)，从偏移量

恢复

(如果未找到)，请根据auto.offset.reset设置偏移量。

如果您想在每次重新启动时阅读整个主题，实际上根本没有理由提交偏移量。提交偏移量的目的是知道您的位置，因为您要在重新启动后从该偏移量恢复。