如何从Kafka主题中检索最新消息

Question

我只是Kafka的新手，我有个问题：

我在Kafka中有一个主题“A”，我启动Spring boot应用程序并使用MessageChannel向主题“A”发送一些消息，然后我停止应用程序。

当我再次启动应用程序时，是否可以获取我发送到主题“A”的最新消息（并非所有消息）？我搜索了所有的解决方案，但它们对我帮助不大，如果我只发送新消息，它总是会立即收到消息。如果你有可运行的代码，请分享，我非常感谢：(

    // Start application


    // Get latest message in topic 'A' then do some LOGIC
    if (exist latest message) {
          //Print latest message
    }

Answer 1

消费者存储其偏移量（即上次读取的位置）。重启后，他们继续从这一点读取。这种行为是故意的。

当由于某种原因（例如，它是一个新的消费群体或偏移量已过期）尚未知道此特定消费群体的偏移量时，将使用偏移量重置属性，但通常有两个选项-a）从头开始重新读取b）开始侦听新消息，忘记以前的一切。

有很多方法可以实现您所描述的内容，但它们并不简单且不推荐（一个微不足道的方法：消费者消息，同时跳过它们，直到您到达分区EOF）

也许Kafka不是解决这个问题的正确工具。