[KAFKA-1262] Producer halts on broker bounces

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Cannot Reproduce
• Affects Version/s: 0.10.1.0
• Component/s: producer
• Assignee: Jay Kreps
• Reporter: Neha Narkhede
• Created: 13/Feb/14 03:49
• Updated: 07/Mar/14 02:43
• Resolved: 07/Mar/14 02:43

Description

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)