Neha Narkhede created KAFKA-1262:
------------------------------------
Summary: 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)
