When machine with kafka dies, most often broker cannot start itself with errors about index files being corrupt. After i delete them manually broker usually can boot up successfully. Shouldn't kafka try to delete/rebuild broken index files itself?
Also this exception looks a bit weird: java.lang.IllegalArgumentException: requirement failed: Corrupt index found, index file (/disk1/kafka-logs/benchmark-2/00000000000000385258.index) has non-zero size but the last offset is 385258 and the base offset is 385258 Thanks.