2016-03-04 250 views
1

有没有人知道这个错误的含义?kafka.common.KafkaStorageException:无法将日志文件后缀从.deleted更改为日志段0

kafka.common.KafkaStorageException: Failed to change the log file suffix from to .deleted for log segment 0 
at kafka.log.LogSegment.changeFileSuffixes(LogSegment.scala:259) 
at kafka.log.Log.kafka$log$Log$$asyncDeleteSegment(Log.scala:729) 
at kafka.log.Log.kafka$log$Log$$deleteSegment(Log.scala:720) 
at kafka.log.Log$$anonfun$deleteOldSegments$1.apply(Log.scala:488) 
at kafka.log.Log$$anonfun$deleteOldSegments$1.apply(Log.scala:488) 
at scala.collection.immutable.List.foreach(List.scala:318) 
at kafka.log.Log.deleteOldSegments(Log.scala:488) 
at kafka.log.LogManager.kafka$log$LogManager$$cleanupExpiredSegments(LogManager.scala:411) 
at kafka.log.LogManager$$anonfun$cleanupLogs$3.apply(LogManager.scala:442) 
at kafka.log.LogManager$$anonfun$cleanupLogs$3.apply(LogManager.scala:440) 
at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772) 
at scala.collection.Iterator$class.foreach(Iterator.scala:727) 
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) 
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) 
at scala.collection.AbstractIterable.foreach(Iterable.scala:54) 
at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771) 
at kafka.log.LogManager.cleanupLogs(LogManager.scala:440) 
at kafka.log.LogManager$$anonfun$startup$1.apply$mcV$sp(LogManager.scala:182) 
at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:99) 
at kafka.utils.Utils$$anon$1.run(Utils.scala:54) 
at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) 
at java.util.concurrent.FutureTask.runAndReset(Unknown Source) 
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source) 
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source) 
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) 
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) 
at java.lang.Thread.run(Unknown Source) 

卡夫卡似乎工作,但我想知道什么是对的消息。

回答

1

似乎这发生在kafka试图在文件仍然打开时重命名文件时发生。这是issue的报告。

+0

谢谢你!你知道这个问题是否已经解决?它看起来还在等待..但是,jira指的是0.8.1,而我与0.8.2有相同的问题。 – OGrandeDiEnne

0

的解决方法是删除你的卡夫卡日志: C:\ tmp目录\卡夫卡日志 C:\ tmp目录\饲养员

在写这个答案的existing bug仍然突出的时间。