Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> java.io.IOException: Broken pipe

Copy link to this message
Re: java.io.IOException: Broken pipe
From the error it seems that the server was not able to write the fetch
response on the socket since the socket was closed. Do you see any errors
on the consumer on <> ? The consumer could've
closed the socket due to some error or could've died.


On Friday, March 15, 2013, Yonghui Zhao wrote:

> This exception happened many times in high through put in kafka 0.7.2
> [2013-03-15 17:27:16,691] ERROR Closing socket for / because
> of
> error (kafka.network.Processor)
> java.io.IOException: Broken pipe
>     at sun.nio.ch.FileChannelImpl.transferTo0(Native Method)
>     at
> sun.nio.ch.FileChannelImpl.transferToDirectly(FileChannelImpl.java:456)
>     at sun.nio.ch.FileChannelImpl.transferTo(FileChannelImpl.java:557)
>     at kafka.message.FileMessageSet.writeTo(FileMessageSet.scala:102)
>     at kafka.server.MessageSetSend.writeTo(MessageSetSend.scala:53)
>     at kafka.network.MultiSend.writeTo(Transmission.scala:91)
>     at kafka.network.Processor.write(SocketServer.scala:339)
>     at kafka.network.Processor.run(SocketServer.scala:216)
>     at java.lang.Thread.run(Thread.java:679)
> It seems it doesn't matter much.
> I want to know if we need take actions if we see this exception.