1.概述
最近看一个kafka集群出问题了,然重启又如下日志 Found a corrupted index file corresponding to log file recovering segment and rebuilding index files...
文章重复:【kafka】kafka 启动的时候 日志 find a corrupted index file
具体如下
这里想看看这是为什么。
2.源码分析
/**
* This method does not need to convert IOException to KafkaStorageException because it is only called before all logs are loaded
* It is possible that we encounter a segment with index offset overflow in which case the LogSegmentOffsetOverflowException
* will be thrown. Note that any segments that were opened befo