apache-kafka - 如何在 kafkalistener 中设置偏移量

Question

我正在尝试使用来自 kafka 服务器的数据，我正在使用 @Kafkalistener注解。

问题是每次重新启动应用程序时我都会收到所有消息。
如何在我的应用程序中保存上次使用的偏移量并使用它来使用下一条消息？

Answer 1

本教程给出了答案:
https://www.codenotfound.com/spring-kafka-boot-example.html

The kafka.consumer.auto-offset-reset property needs to be set to 'earliest' which ensures the new consumer group will get the message sent in case the container started after the send was completed.

所以你应该根据你的要求将它设置为最新