2016-03-04 32 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仍然突出的時間。