[jira] [Created] (KAFKA-1257) New producer runs into out of order producer responses

[Neha Narkhede (JIRA)]

Neha Narkhede created KAFKA-1257:
------------------------------------

             Summary: New producer runs into out of order producer responses
                 Key: KAFKA-1257
                 URL: https://issues.apache.org/jira/browse/KAFKA-1257
             Project: Kafka
          Issue Type: Sub-task
          Components: producer 
    Affects Versions: 0.9.0
            Reporter: Neha Narkhede
            Priority: Blocker


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)




--
This message was sent by Atlassian JIRA
(v6.1.5#6160)