Lea created KAFKA-12859:
---------------------------
Summary: 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
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)
