Hi,
We got this below error in our production set-up. We then tried to read
from kafka consumer shell, we got this error again 2-3 times, but after
that it started working and now, we arent able to reproduce. Any indicator
on why this error occurs and how it auto corrected..

Googling got me to some kafka messages which pointed to corrupt files, but
am not sure why we arent able to reproduce it any-more.

Version of kafka : 0.8.2


ERROR [2017-05-09 16:27:38,189] [kafka-network-thread-9092-1][]
kafka.network.Processor - Closing socket for  because of error
java.io.IOException: Input/output error
        at sun.nio.ch.FileChannelImpl.transferTo0(Native Method)
        at
sun.nio.ch.FileChannelImpl.transferToDirectlyInternal(FileChannelImpl.java:428)
        at
sun.nio.ch.FileChannelImpl.transferToDirectly(FileChannelImpl.java:493)
        at sun.nio.ch.FileChannelImpl.transferTo(FileChannelImpl.java:608)
        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)

Reply via email to