源码查看:error code 2:This message has failed its CRC checksum, exceeds the valid size, or is otherwise corrupt.由于数据损坏,不完整,CRC校验失败,offset无法跳过,一直报错,有什么好的处理 查看kafka server.log日志,发现报错 这个报错未找到引发的原因
解决方法 https://www.cnblogs.com/yudizhao/p/13230003.html
平时不来这个论坛,有问题在上面这个链接里面交流吧
请问楼主解决了这个问题没有,我也遇见这个问题了
很可能是消息超过了限制,默认是1M的。你把message.max.bytes改大试试。
你的答案