kafka消费者消费数据,我插入数据库的时候报错了,去扑捉异常了,为什么会一直重复进行消费这个错误数据呢

scattered and scattered 发表于: 2020-02-18   最后更新时间: 2020-02-18 10:19:51   1,665 游览

我今天测试数据,故意插入数据库失败,然后我也去扑捉异常了,然后扑捉到这个异常然后就默认当消费了这个数据,发现还是不行,还是会一致发送需要消费这个数据,应该怎么解决呢?

发表于 2020-02-18
¥1.0

我不太清楚你的消费者类是如果提交offset的,如果自动提交,正常你不往上抛异常,就没问题。会认为你消费了。
另外,你这条异常数据是消费者一启动,就先消费它,还是连之前的正常消息也会重新消费?

自动提交的,我发现问题了,是我打断点了,导致时间延长了,引起消费者重送机智了,谢谢大佬

你的答案

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