Hello,

I've run into an issue with Kafka 0.8.1.1 broker. The broker stopped
working after the disk it was writing to ran out of space. I freed up some
space and tried to restart the broker. It started some recovery procedure,
but after some short time in the logs I see the following strange error
message:

FATAL kafka.server.KafkaServerStartable  - Fatal error during
KafkaServerStable startup. Prepare to shutdown
java.lang.InternalError: a fault occurred in a recent unsafe memory access
operation in compiled Java code
        at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:39)
        at java.nio.ByteBuffer.allocate(ByteBuffer.java:312)
        at
kafka.log.FileMessageSet$$anon$1.makeNext(FileMessageSet.scala:188)
        at
kafka.log.FileMessageSet$$anon$1.makeNext(FileMessageSet.scala:165)
        at
kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
        at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
        at kafka.log.LogSegment.recover(LogSegment.scala:165)
        at kafka.log.Log.recoverLog(Log.scala:179)
        at kafka.log.Log.loadSegments(Log.scala:155)
        at kafka.log.Log.<init>(Log.scala:64)
        at
kafka.log.LogManager$$anonfun$loadLogs$1$$anonfun$apply$4.apply(LogManager.scala:118)
        at
kafka.log.LogManager$$anonfun$loadLogs$1$$anonfun$apply$4.apply(LogManager.scala:113)
        at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
        at
scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:105)
        at
kafka.log.LogManager$$anonfun$loadLogs$1.apply(LogManager.scala:113)
        at
kafka.log.LogManager$$anonfun$loadLogs$1.apply(LogManager.scala:105)
        at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
        at
scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)
        at kafka.log.LogManager.loadLogs(LogManager.scala:105)
        at kafka.log.LogManager.<init>(LogManager.scala:57)
        at kafka.server.KafkaServer.createLogManager(KafkaServer.scala:275)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:72)
        at
kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34)
        at kafka.Kafka$.main(Kafka.scala:46)
        at kafka.Kafka.main(Kafka.scala)

and then everything starts over. I've been waiting for a while, but the
broker keeps restarting. How can I bring it back to life?

Thanks!

Reply via email to