spring-kafka 怎么实现跳过历史数据

光年 发表于: 2021-07-23   最后更新时间: 2021-07-24 22:19:29   1,883 游览

我使用springboot集成kafka,当前springboot在停止期间依然有生产者在生产数据,springboot 并不需要停止运行期产生的数据。请问大佬这个该如何配置?膜拜大佬!

发表于 2021-07-23

1、 将group.id换成新的名字(相当于加入新的消费组)

2、 网上文章写还要设置 properties.setProperty("auto.offset.reset", "latest”)

实验发现即使不设置这个,只要group.id是全新的,就会从最新的的offset开始消费。

你的答案

查看kafka相关的其他问题或提一个您自己的问题