kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Arya Ketan <ketan.a...@gmail.com>
Subject Kafka Socket error
Date Tue, 09 May 2017 16:36:05 GMT
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)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message