[
https://issues.apache.org/jira/browse/KAFKA-12859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lea updated KAFKA-12859:
------------------------
Description:
When the client producer data, the Kafka server repeatedly responds with the
same correlationId. As a result, all requests subsequent to the socket fail to
be sent.
{code:java}
//
java.lang.IllegalStateException: Correlation id for response (30205) does not
match request (30211), request header: RequestHeader(apiKey=PRODUCE,
apiVersion=5, clientId=producer-1, correlationId=30211)
at
org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:943)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:713)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:836)
~[kafka-clients-2.4.0.jar!/:na]
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)
~[kafka-clients-2.4.0.jar!/:na]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_141]
{code}
was:
When the client producer data, the Kafka server repeatedly responds with the
same correlationId. As a result, all requests subsequent to the socket fail to
be sent.
异常如下
{code:java}
//
java.lang.IllegalStateException: Correlation id for response (30205) does not
match request (30211), request header: RequestHeader(apiKey=PRODUCE,
apiVersion=5, clientId=producer-1, correlationId=30211)
at
org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:943)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:713)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:836)
~[kafka-clients-2.4.0.jar!/:na]
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335)
~[kafka-clients-2.4.0.jar!/:na]
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)
~[kafka-clients-2.4.0.jar!/:na]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_141]
{code}
> Kafka Server Repeated Responses
> -------------------------------
>
> Key: KAFKA-12859
> URL: https://issues.apache.org/jira/browse/KAFKA-12859
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 1.1.0
> Reporter: Lea
> Priority: Critical
> Attachments: 截图1.PNG, 截图3.PNG, 截图4.PNG, 截图5.PNG
>
>
> When the client producer data, the Kafka server repeatedly responds with the
> same correlationId. As a result, all requests subsequent to the socket fail
> to be sent.
> {code:java}
> //
> java.lang.IllegalStateException: Correlation id for response (30205) does not
> match request (30211), request header: RequestHeader(apiKey=PRODUCE,
> apiVersion=5, clientId=producer-1, correlationId=30211)
> at
> org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:943)
> ~[kafka-clients-2.4.0.jar!/:na]
> at
> org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:713)
> ~[kafka-clients-2.4.0.jar!/:na]
> at
> org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:836)
> ~[kafka-clients-2.4.0.jar!/:na]
> at
> org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549)
> ~[kafka-clients-2.4.0.jar!/:na]
> at
> org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335)
> ~[kafka-clients-2.4.0.jar!/:na]
> at
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)
> ~[kafka-clients-2.4.0.jar!/:na]
> at java.lang.Thread.run(Thread.java:748) [na:1.8.0_141]
> {code}
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
