springboot+kafka手动提交offset

蝈蝈0101 发布于 09/18 16:59
阅读 173
收藏 0

springboot加kafka,需要从kafka成功拉取数据之后,对数据进行相应的处理之后再进行提交。如拉取数据之后进行写入mysql这种 , 所以这时我们就需要进行手动提交kafka的offset下标,这个需要该怎么做呢?

加载中
0
曹冲
曹冲
Acknowledgment
蝈蝈0101
蝈蝈0101
回复 @曹冲 : 谢谢您
曹冲
曹冲
回复 @蝈蝈0101 : 多一条数据?是重复数据吧,如果是重复数据哪你要去重
蝈蝈0101
蝈蝈0101
是的,确实这样做了,但是接收端是做数据库持久化,每次接收端宕机之后重启,就会多一条数据,这样是什么原因呢?
返回顶部
顶部