[ https://issues.apache.org/jira/browse/KAFKA-540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jun Rao updated KAFKA-540: -------------------------- Attachment: kafka-540.patch Attach a patch to fix the issue. > log.append() should halt on IOException > --------------------------------------- > > Key: KAFKA-540 > URL: https://issues.apache.org/jira/browse/KAFKA-540 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8 > Reporter: Jun Rao > Priority: Blocker > Labels: bugs > Fix For: 0.8 > > Attachments: kafka-540.patch > > Original Estimate: 24h > Remaining Estimate: 24h > > See the following entry in the broker log in a system test run. We > interrupted the ReplicaFetcherThread during shutdown. However, log.append > halts the system when we hit the interrupted exception. The fix is not to > halt the system in log.append and just pass on the exception. The caller can > decide what to do. > [2012-10-03 15:08:53,124] FATAL [Kafka Log on Broker 2], Halting due to > unrecoverable I/O error while handling producer request (kafka.log.Log) > java.nio.channels.ClosedByInterruptException > at > java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:184) > at sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:203) > at > kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:128) > at kafka.log.FileMessageSet.append(FileMessageSet.scala:155) > at kafka.log.LogSegment.append(LogSegment.scala:60) > at kafka.log.Log.liftedTree1$1(Log.scala:282) > at kafka.log.Log.append(Log.scala:270) > at > kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:42) > at > kafka.server.AbstractFetcherThread$$anonfun$doWork$5.apply(AbstractFetcherThread.scala:105) > at > kafka.server.AbstractFetcherThread$$anonfun$doWork$5.apply(AbstractFetcherThread.scala:98) > at scala.collection.immutable.Map$Map1.foreach(Map.scala:105) > at > kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:98) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:50) > ( -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira