Mag*_*i87 6 apache-kafka kafka-consumer-api spring-kafka
我正在尝试使用来自 kafka 服务器的数据，我正在使用@Kafkalistener注释。
问题是每次重新启动应用程序时我都会收到所有消息。如何在我的应用程序中保存上次使用的偏移量并使用它来使用下一条消息？
小智 3
本教程有答案： https ://www.codenotfound.com/spring-kafka-boot-example.html
kafka.consumer.auto-offset-reset 属性需要设置为“earliest”，以确保新的消费者组将收到发送的消息，以防容器在发送完成后启动。
所以你应该根据你的要求将其设置为最新
| 归档时间： |
|
| 查看次数： |
2342 次 |
| 最近记录： |