【kafka】kafkarecordiscorrupt（记录损坏）

1.概述

转载&＃xff1a;kafka消费者无法消费异常

我忘记我为啥遇到这个问题了&＃xff0c;转载一下

今天被一个kafka消费异常折磨了一天&＃xff0c;头差点炸了&＃xff0c;还好最后解决了它

异常&＃xff1a;服务器&＃xff1a;record is corrupt&＃xff08;记录损坏&＃xff09;不明原因 有可能磁盘空间不足导致 导致消费者无法正常消费消息 卡在某一个offset 不能继续消费

解决办法&＃xff1a;先停掉消费者程序 杀掉进程&＃xff08;不可关闭kafka服务&＃xff09;然后手动设置偏移量 跳过卡在的offset位置

进入kafka目录&＃xff0c;命令&＃xff1a;

bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --group groupName --reset-offsets --to-offset 1000 --topic topicName --execute

然后重启消费者程序 ok

该问题和 【Kafka】Kafka Record for partition topic at offset xx is invalid, cause: Record corrupt 重复问题。