kafka消息损坏,消费者一直循环消费

kafka里面当前消息2942497,invalid是false

img


项目中报错

img

并且会一直循环输出这个错误
之前有用过配置kafka跳过此消息,但是每次都要手动去修改,有没有办法在报错后,跳过此消息

kafka没有重试机制不支持消息重试,也没有死信队列,因此使用kafka做消息队列时,如果遇到了消息在业务处理时出现异常,就会很难进行下一步处理。应对这种场景,需要自己实现消息重试的功能。

捕获异常消息,自行处理