【发布时间】：2017-10-27 08:19:38
【问题描述】：
我正在尝试使用来自 kafka 服务器的数据，我正在使用 @Kafkalistener 注释。
问题是我每次重新启动应用程序时都会收到所有消息。 如何在我的应用程序中保存上次使用的偏移量并使用它来使用下一条消息？
【问题讨论】：
标签： apache-kafka kafka-consumer-api spring-kafka
【发布时间】：2017-10-27 08:19:38
【问题描述】：
本教程有答案： https://www.codenotfound.com/spring-kafka-boot-example.html
需要将 kafka.consumer.auto-offset-reset 属性设置为 'earliest' 确保新的消费者组将收到消息 在发送完成后容器启动的情况下发送。
所以你应该根据你的要求将它设置为最新
【讨论】：