我使用springboot集成kafka,当前springboot在停止期间依然有生产者在生产数据,springboot 并不需要停止运行期产生的数据。请问大佬这个该如何配置?膜拜大佬!
1、 将group.id换成新的名字(相当于加入新的消费组)
group.id
2、 网上文章写还要设置 properties.setProperty("auto.offset.reset", "latest”)
properties.setProperty("auto.offset.reset", "latest”)
实验发现即使不设置这个,只要group.id是全新的,就会从最新的的offset开始消费。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
1、 将
group.id
换成新的名字(相当于加入新的消费组)2、 网上文章写还要设置
properties.setProperty("auto.offset.reset", "latest”)
实验发现即使不设置这个,只要
group.id
是全新的,就会从最新的的offset开始消费。你的答案