You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Enhon Bryant (Jira)" <ji...@apache.org> on 2019/12/13 06:29:00 UTC
[jira] [Created] (KAFKA-9296) Correlation id for response () does
not match request ()
Enhon Bryant created KAFKA-9296:
-----------------------------------
Summary: Correlation id for response () does not match request ()
Key: KAFKA-9296
URL: https://issues.apache.org/jira/browse/KAFKA-9296
Project: Kafka
Issue Type: Bug
Components: clients, producer
Affects Versions: 1.0.2
Environment: Flink on k8s
Reporter: Enhon Bryant
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)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)