目前用的是kafka1.1.0版本
经常因为index文件损坏, 导致kafka连接不上
[2018-09-12 13:59:25,965] ERROR Error while loading log dir D:\Program Files\kafka\kafka_2.11-1.0.1\logs (kafka.log.LogManager)
java.nio.file.FileSystemException: D:\Program Files\kafka\kafka_2.11-1.0.1\logs\__consumer_offsets-37\00000000000000000000.timeindex: ÁíÒ»¸ö³ÌÐòÕýÔÚʹÓôËÎļþ£¬½ø³ÌÎÞ·¨·ÃÎÊ¡£
at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:86)
at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:102)
at sun.nio.fs.WindowsFileSystemProvider.implDelete(WindowsFileSystemProvider.java:269)
at sun.nio.fs.AbstractFileSystemProvider.deleteIfExists(AbstractFileSystemProvider.java:108)
看1.1.1的更新日志 有解决相关的问题
https://www.apache.org/dist/kafka/1.1.1/RELEASE_NOTES.html
[KAFKA-6854] - Log cleaner fails with transaction markers that are deleted during clean