Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1239 New producer checklist
  3. KAFKA-1257

New producer runs into out of order producer responses

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • 0.10.1.0
    • None
    • producer
    • None

    Description

      Ran into the following bug while running the new mirror maker on one large topic -

      java.lang.IllegalStateException: Correlation id for response (13502150) does not match request (13502149)
      at org.apache.kafka.clients.producer.internals.Sender.correlate(Sender.java:333)
      at org.apache.kafka.clients.producer.internals.Sender.handleResponses(Sender.java:289)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:158)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
      at java.lang.Thread.run(Thread.java:619)
      java.lang.IllegalStateException: Correlation id for response (13502151) does not match request (13502150)
      at org.apache.kafka.clients.producer.internals.Sender.correlate(Sender.java:333)
      at org.apache.kafka.clients.producer.internals.Sender.handleResponses(Sender.java:289)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:158)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)
      at java.lang.Thread.run(Thread.java:619)
      java.lang.IllegalStateException: Correlation id for response (13502152) does not match request (13502151)
      at org.apache.kafka.clients.producer.internals.Sender.correlate(Sender.java:333)
      at org.apache.kafka.clients.producer.internals.Sender.handleResponses(Sender.java:289)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:158)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:98)

      Attachments

        1. KAFKA-1257_2014-02-11_17:11:54.patch
          2 kB
          Jay Kreps
        2. KAFKA-1257_2014-02-11_17:14:48.patch
          3 kB
          Jay Kreps
        3. KAFKA-1257.patch
          3 kB
          Jay Kreps

        Activity

          People

            jkreps Jay Kreps
            nehanarkhede Neha Narkhede
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: