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

scattered and scattered 发表于: 2020-02-18   最后更新时间: 2020-02-18  

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



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: 用java写的kafka,开始运行消费者后,不杀进程的条件下,有什么办法可以停止消费者呢?
下一条: 关于Kafka集群 消费者生产者内外网访问的问题?

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