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

起风了 发表于: 2021-09-22   最后更新时间: 2021-09-22 18:13:07   160 游览

多节点情况下,只有这个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.



添加评论

kafka的bug,网咯协议返回包序号不一致导致的。

通过升级kafka版本来解决:

  • 已修复的版本有:0.11.0.1,1.0.0

ps:小版本里选最新

问题bug报告可参考:
https://issues.apache.org/jira/browse/KAFKA-9296

起风了 -> 半兽人 1月前

这个bug触发条件是发的太快了吗?

半兽人 -> 起风了 1月前

网络繁忙,还有cpu高也会引起的。

起风了 -> 半兽人 1月前

9296这个问题现在还是开发状态,显示没有修复版本。

半兽人 -> 起风了 1月前

嗯,文章里面有关联连接,那个显示了修复版本。

你的答案

查看kafka相关的其他问题或提一个您自己的问题

找不到想要的答案?提一个您自己的问题。

我要提问
提问