提问说明

kafka再运行一天左右的时间就会出现这个错误，然后就停止了服务。
kafka版本为2.3.1版本，在Windows环境下

ERROR Failed to clean up log for __consumer_offsets-22 in dir E:\kafka\kafka_2.11-2.3.1\bin\windows\kafkalogsdata-333 due to IOException (kafka.server.LogDirFailureChannel)
java.nio.file.FileSystemException: E:\kafka\kafka_2.11-2.3.1\bin\windows\kafkalogsdata-333\__consumer_offsets-22\00000000000000000000.index.cleaned -> E:\kafka\kafka_2.11-2.3.1\bin\windows\kafkalogsdata-333\__consumer_offsets-22\00000000000000000000.index.swap: 另一个程序正在使用此文件，进程无法访问。
    at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:86)
    at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
    at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:387)
    at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
    at java.nio.file.Files.move(Files.java:1395)
    at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:815)
    at kafka.log.AbstractIndex.renameTo(AbstractIndex.scala:209)
    at kafka.log.LogSegment.changeFileSuffixes(LogSegment.scala:509)
    at kafka.log.Log$$anonfun$replaceSegments$1.apply(Log.scala:2036)
    at kafka.log.Log$$anonfun$replaceSegments$1.apply(Log.scala:2036)
    at scala.collection.immutable.List.foreach(List.scala:392)
    at kafka.log.Log.replaceSegments(Log.scala:2036)
    at kafka.log.Cleaner.cleanSegments(LogCleaner.scala:602)
    at kafka.log.Cleaner$$anonfun$doClean$4.apply(LogCleaner.scala:528)
    at kafka.log.Cleaner$$anonfun$doClean$4.apply(LogCleaner.scala:527)
    at scala.collection.immutable.List.foreach(List.scala:392)
    at kafka.log.Cleaner.doClean(LogCleaner.scala:527)
    at kafka.log.Cleaner.clean(LogCleaner.scala:501)
    at kafka.log.LogCleaner$CleanerThread.cleanLog(LogCleaner.scala:359)
    at kafka.log.LogCleaner$CleanerThread.cleanFilthiestLog(LogCleaner.scala:328)
    at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:307)
    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:89)
Suppressed: java.nio.file.FileSystemException: E:\kafka\kafka_2.11-2.3.1\bin\windows\kafkalogsdata-333\__consumer_offsets-22\00000000000000000000.index.cleaned -> E:\kafka\kafka_2.11-2.3.1\bin\windows\kafkalogsdata-333\__consumer_offsets-22\00000000000000000000.index.swap: 另一个程序正在使用此文件，进程无法访问。
    at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:86)
    at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
    at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:301)
    at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
    at java.nio.file.Files.move(Files.java:1395)
    at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:812)
    ... 16 more

预览