Kafka 啟動失敗，報錯Corrupt index found以及org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'version': java.nio.BufferUnderflowException

貼出大佬的博客https://blog.csdn.net/lzxlfly/article/details/90308285

報錯截圖如下

 

 

 

 看報錯信息就可以知道是因為沒有正常關閉Kafka，導致文件的索引出現了問題

解決方案

刪除掉Kafka數據目錄里的所有 .index  和  .timeindex 文件，然后重啟Kafka，讓它重新建立索引

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

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