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

Question

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

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

提前致谢。

Answer 1

使用here 中描述的组消费者并使用offset latest。然后它会消费组消费者订阅后产生的消息。