Kafka 启动失败，报错Corrupt index found以及org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'version': java.nio.BufferUnderflowException

今天启动kafka 后 发现只有一个节点启动成功，另两个节点启动失败，查看日志如下

经多方查验，原来是之前未正常关闭服务导致

解决方案

根据日志提示，我们需要手动删除每个partition下的 两个索引文件， 重新启动集群，kafka会自动重建索引文件

find /opt/module/kafka/logs/ -name "*.timeindex" |xargs rm -f
find /opt/module/kafka/logs/ -name "*.index" |xargs rm -f

重启服务即可。

参考：https://blog.csdn.net/lzxlfly/article/details/90308285