kafka发送失败 Correlation id for response (19685882) does not match request (19685878) 修订版本明细

源

采纳

编辑于 3年前

起风了

kafka发送失败 Correlation id for response (19685882) does not match request (19685878)

kafka

多节点情况下，只有这个kafka producer生产者有问题

错误日志如下：

ERROR Sender - Uncaught error in kafka producer I/O thread:
java.lang.IllegalStateException: Correlation id for response (19685882) does not match request (19685878)
        at org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:486)
        at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:381)
        at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:449)
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:269)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:229)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
        at java.lang.Thread.run(Thread.java:748)

The server disconnected before a response was received.
org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received.

预览