[ https://issues.apache.org/jira/browse/KAFKA-12859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lea updated KAFKA-12859: ------------------------ Attachment: 截图1.PNG > 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 > > > 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)