windows下kafka1.0源码环境，日志清理报错，直接退出程序

Question

[2018-06-19 15:08:57,934] ERROR Error while loading log dir D:WORK02-KAFKAkafka-1.0.1-srckafka-logs (kafka.log.LogManager)
java.nio.file.FileSystemException: D:WORK02-KAFKAkafka-1.0.1-srckafka-logsepp_account_active_producer-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)
	at java.nio.file.Files.deleteIfExists(Files.java:1165)
	at kafka.log.Log$$anonfun$loadSegmentFiles$3.apply(Log.scala:335)
	at kafka.log.Log$$anonfun$loadSegmentFiles$3.apply(Log.scala:297)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:733)
	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
	at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:732)
	at kafka.log.Log.loadSegmentFiles(Log.scala:297)
	at kafka.log.Log.loadSegments(Log.scala:406)
	at kafka.log.Log.<init>(Log.scala:203)
	at kafka.log.Log$.apply(Log.scala:1734)
	at kafka.log.LogManager.kafka$log$LogManager$$loadLog(LogManager.scala:221)
	at kafka.log.LogManager$$anonfun$loadLogs$2$$anonfun$8$$anonfun$apply$16$$anonfun$apply$2.apply$mcV$sp(LogManager.scala:292)
	at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:61)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
	at java.util.concurrent.FutureTask.run(FutureTask.java)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

 

Answer 1

kafka进程直接重启，就会遇到这种情况

Answer 2

文件处理完关闭了吗