[
https://issues.apache.org/jira/browse/KAFKA-9296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294831#comment-17294831
]
Cruz Fernandez commented on KAFKA-9296:
---------------------------------------
I'm seeing a very similar error on my Kafka-Connect setup:
{code:java}
java.lang.IllegalStateException: Correlation id for response (388403) does not
match request (388402), request header: RequestHeader(apiKey=HEARTBEAT,
apiVersion=4, clientId=connector-consumer-snowflake-xxxx-yyyyy-redacted-0,
correlationId=388402)
at org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:943)
at
org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:713)
at
org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:836)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1240)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.pollConsumer(WorkerSinkTask.java:444)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:317)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:224)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:192)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
{code}
I'll explain a little bit my kubernetes/strimzi setup if it helps:
* strimzi operator creates kafka connect with CRDs
* main jar version kafka_2.12-2.4.0.jar
* kafka-clients-2.4.0.jar
* snowflake kafka connector version 1.5.2
Should I be worried this might happen again?
> 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)
