[KAFKA-9296] Correlation id for response () does not match request ()

• Type: Bug
• Status: Open
• Priority: Blocker
• Resolution: Unresolved
• Affects Version/s: 0.11.0.2
• Component/s: clients, producer
• Labels: kafka producer
• Environment: Flink on k8s
• Assignee: Unassigned
• Reporter: Enhon Bryant
• Reviewer: Jun Rao
• Created: 13/Dec/19 06:28
• Updated: 07/Apr/22 22:06

Description

The Kafka client and broker I use are both version 0.11.0.2.   I use Kafka's producer to write data to broker. I encountered the following exceptions.

2019-12-12 18:12:46,821 ERROR org.apache.kafka.clients.producer.internals.Sender - Uncaught error in kafka producer I/O thread:
java.lang.IllegalStateException: Correlation id for response (11715816) does not match request (11715804), request header: {api_key=0,api_version=3,correlation_id=11715804,client_id=producer-3}
at org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:752)
at org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:561)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:657)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:442)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:224)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:162)
at java.lang.Thread.run(Thread.java:748)

Issue Links

• is related to: KAFKA-4669 KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception