[KAFKA-1257] New producer runs into out of order producer responses

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.10.1.0
• Component/s: producer
• Assignee: Jay Kreps
• Reporter: Neha Narkhede
• Created: 11/Feb/14 18:30
• Updated: 13/Feb/14 18:34
• Resolved: 13/Feb/14 18:34

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)