[
https://issues.apache.org/jira/browse/KAFKA-9296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348627#comment-17348627
]
Lea commented on KAFKA-9296:
----------------------------
I had the same problem using kafka producer again.
Environment: K8S POD
At the same time, I find that the TCP retransmission error rate of the node
increases to 2%. I don't know whether this is related to this.
{code:java}
//代码占位符
{code}
2021-05-19 12:39:34.308 [] [kafka-producer-network-thread |
314c35d9-10fd-44e4-9f96-1a60805b250d] ERROR o.a.k.c.producer.internals.Sender
run 246 - [Producer clientId=314c35d9-10fd-44e4-9f96-1a60805b250d] Uncaught
error in kafka producer I/O thread: java.lang.IllegalStateException:
Correlation id for response (80779915) does not match request (80779910),
request header: RequestHeader(apiKey=PRODUCE, apiVersion=5,
clientId=314c35d9-10fd-44e4-9f96-1a60805b250d, correlationId=80779910) at
org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:937) at
org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:720)
at
org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:833)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:556) at
org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335) at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244) at
java.lang.Thread.run(Thread.java:748)
> 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: 0.11.0.2
> Environment: Flink on k8s
> Reporter: Enhon Bryant
> Priority: Blocker
> Labels: kafka, producer
>
> 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)
