Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Blocker
    • Resolution: Cannot Reproduce
    • Affects Version/s: 0.10.1.0
    • Fix Version/s: None
    • Component/s: producer
    • Labels:
      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)

        Attachments

          Activity

            People

            • Assignee:
              jkreps Jay Kreps
              Reporter:
              nehanarkhede Neha Narkhede
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: