You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2014/02/13 04:50:19 UTC

[jira] [Created] (KAFKA-1262) Producer halts on broker bounces

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)