我正在尝试使用kafka服务器的数据，我正在使用 @Kafkalistener 注解。问题是每次重新启动应用程序时都会收到所有消息。如何在应用程序中保存上次使用的偏移量并使用它来使用下一条消息？
@Kafkalistener
mw3dktmi1#
本教程给出了答案：https://www.codenotfound.com/spring-kafka-boot-example.htmlkafka.consumer.auto-offset-reset属性需要设置为'earliest'，以确保在发送完成后启动容器时，新的使用者组将收到发送的消息。所以你应该根据你的要求把它设置为最新的
1条答案
按热度按时间mw3dktmi1#
本教程给出了答案：https://www.codenotfound.com/spring-kafka-boot-example.html
kafka.consumer.auto-offset-reset属性需要设置为'earliest'，以确保在发送完成后启动容器时，新的使用者组将收到发送的消息。
所以你应该根据你的要求把它设置为最新的