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)

        Activity

        Hide
        nehanarkhede Neha Narkhede added a comment -

        I think this is fixed now.

        Show
        nehanarkhede Neha Narkhede added a comment - I think this is fixed now.
        Hide
        nehanarkhede Neha Narkhede added a comment -

        We saw this issue again today.

        Show
        nehanarkhede Neha Narkhede added a comment - We saw this issue again today.

          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:

              Development