[
https://issues.apache.org/jira/browse/KAFKA-1262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13912406#comment-13912406
]
Neha Narkhede commented on KAFKA-1262:
--------------------------------------
We saw this issue again today.
> Producer halts on broker bounces
> --------------------------------
>
> Key: KAFKA-1262
> URL: https://issues.apache.org/jira/browse/KAFKA-1262
> Project: Kafka
> Issue Type: Sub-task
> Components: producer
> Affects Versions: 0.9.0
> Reporter: Neha Narkhede
> Assignee: Jay Kreps
> Priority: Blocker
>
> In a test using the new mirror maker, the producer stopped with the following
> stack trace the moment the cluster was bounced using controlled shutdown -
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:66)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:222)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:153)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
> at java.lang.Thread.run(Thread.java:619)
> java.io.IOException: Connection reset by peer
> at sun.nio.ch.FileDispatcher.read0(Native Method)
> at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
> at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:237)
> at sun.nio.ch.IOUtil.read(IOUtil.java:210)
> at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236)
> at
> org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:64)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:222)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:153)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
> at java.lang.Thread.run(Thread.java:619)
> java.net.ConnectException: Connection refused
> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> at
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:574)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:213)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:153)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
> at java.lang.Thread.run(Thread.java:619)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:66)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:222)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:153)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
> at java.lang.Thread.run(Thread.java:619)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:66)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:222)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:153)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
> at java.lang.Thread.run(Thread.java:619)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:66)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:222)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:153)
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
> at java.lang.Thread.run(Thread.java:619)
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
