springboot+kafka手动提交offset
springboot加kafka,需要从kafka成功拉取数据之后,对数据进行相应的处理之后再进行提交。如拉取数据之后进行写入mysql这种 , 所以这时我们就需要进行手动提交kafka的offset下标,这个需要该怎么做呢?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(3)
是的,确实这样做了,但是接收端是做数据库持久化,每次接收端宕机之后重启,就会多一条数据,这样是什么原因呢?
回复
多一条数据?是重复数据吧,如果是重复数据哪你要去重
回复
谢谢您