Details
-
Sub-task
-
Status: Resolved
-
Blocker
-
Resolution: Cannot Reproduce
-
0.10.1.0
-
None
-
None
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)