[
https://issues.apache.org/jira/browse/KAFKA-12859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353004#comment-17353004
]
Lea edited comment on KAFKA-12859 at 5/28/21, 6:57 AM:
-------------------------------------------------------
!截图3.PNG!
The above screenshot is printed by Kafka trace log. we can see that the 30211
request received the 30205 response. Through packet capture, it was found that
the request server of 30205 repeatedly sent it twice, as shown in the figure
below.
The serial numbers 105722 and 105726 contain the same correlationid (0x75fd
30205). This causes the kafka client report error.
!截图4.PNG|width=553,height=459!
!截图5.PNG|width=618,height=652!
was (Author: leaye):
!截图3.PNG!
The above screenshot is printed by Kafka trace log. You can see that the 30211
request received the 30205 response. Through packet capture, it was found that
the request server of 30205 repeatedly sent it twice, as shown in the figure
below.
The serial numbers 105722 and 105726 contain the same correlationid (0x75fd
30205). This causes the kafka client report error.
!截图4.PNG|width=553,height=459!
!截图5.PNG|width=618,height=652!
> 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: 截图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)
