[
https://issues.apache.org/jira/browse/KAFKA-2222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14560387#comment-14560387
]
Jason Rosenberg edited comment on KAFKA-2222 at 5/27/15 5:05 AM:
-----------------------------------------------------------------
Interestingly, after restarting the broker, these errors went away (but we did
ultimately declare the disk bad, and had it replaced). But not sure why
restarting resulted in the errors subsiding....
was (Author: jbrosenb...@gmail.com):
Interestingly, after restarting the broker, these errors went away (but we did
ultimately declare the disk bad, and had it replaced). But not sure restarting
resulted in the errors subsiding....
> Write "Input/output error" did not result in broker shutdown
> ------------------------------------------------------------
>
> Key: KAFKA-2222
> URL: https://issues.apache.org/jira/browse/KAFKA-2222
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8.1.2
> Reporter: Jason Rosenberg
>
> We had a disk start failing intermittently, and began seeing errors like this
> in the broker. Usually, IOExceptions during a file write result in the
> broker shutting down immediately. This is with version 0.8.2.1.
> {code}
> 2015-05-21 23:59:57,841 ERROR [kafka-network-thread-27330-2]
> network.Processor - Closing socket for /1.2.3.4 because of error
> java.io.IOException: Input/output error
> at sun.nio.ch.FileChannelImpl.transferTo0(Native Method)
> at
> sun.nio.ch.FileChannelImpl.transferToDirectly(FileChannelImpl.java:443)
> at sun.nio.ch.FileChannelImpl.transferTo(FileChannelImpl.java:575)
> at kafka.log.FileMessageSet.writeTo(FileMessageSet.scala:147)
> at kafka.api.PartitionDataSend.writeTo(FetchResponse.scala:70)
> at kafka.network.MultiSend.writeTo(Transmission.scala:101)
> at kafka.api.TopicDataSend.writeTo(FetchResponse.scala:125)
> at kafka.network.MultiSend.writeTo(Transmission.scala:101)
> at kafka.api.FetchResponseSend.writeTo(FetchResponse.scala:231)
> at kafka.network.Processor.write(SocketServer.scala:472)
> at kafka.network.Processor.run(SocketServer.scala:342)
> at java.lang.Thread.run(Thread.java:745)
> {code}
> This resulted in intermittent producer failures failing to send messages
> successfully, etc.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
