1.概述

转载：kafka消费者无法消费异常

我忘记我为啥遇到这个问题了，转载一下

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

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

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

进入kafka目录，命令：

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 重复问题。