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)