我今天测试数据,故意插入数据库失败,然后我也去扑捉异常了,然后扑捉到这个异常然后就默认当消费了这个数据,发现还是不行,还是会一致发送需要消费这个数据,应该怎么解决呢?
发表于 2020-02-18
我今天测试数据,故意插入数据库失败,然后我也去扑捉异常了,然后扑捉到这个异常然后就默认当消费了这个数据,发现还是不行,还是会一致发送需要消费这个数据,应该怎么解决呢?
我不太清楚你的消费者类是如果提交offset的,如果自动提交,正常你不往上抛异常,就没问题。会认为你消费了。
另外,你这条异常数据是消费者一启动,就先消费它,还是连之前的正常消息也会重新消费?
自动提交的,我发现问题了,是我打断点了,导致时间延长了,引起消费者重送机智了,谢谢大佬
你的答案