apache-kafka - 使用来自主题的最新消息并忽略所有先前发布的消息

Question

假设我有一个主题“测试”已经有一堆消息，现在我想订阅这个主题。但我不想消耗在新订阅之前发布的所有消息。基本上我只想使用订阅后发布的最新消息。

confluent.kafka 库中是否有任何功能可以帮助我实现此功能。

提前致谢。

Answer 1

使用此处描述的 Group Consumer并使用offset latest. 然后它将消费组消费者订阅后产生的消息。