有没有办法使用骆驼获取Kafka主题中产生的最后一条消息？

Question

我有一个带有一个分区的 kafka 主题。当我的服务器重新启动时，我想使用该主题中最后生成的消息。

Answer 1

当您的 Kafka 消费者第一次连接到主题时，您可以根据需要通过配置进行选择

• 从头开始消费整个主题
• 仅使用在您的消费者连接后到达的新消息

但是，从这一刻起，代理会保存您消费者的最新topic offset，并且您的消费者始终会从该偏移量开始继续消费。

要始终只使用最新消息，您必须在开始之前更改消费者的主题偏移量。