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

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

多节点情况下，只有这个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
发表于 2021-09-22
起风了
添加评论

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

通过升级kafka版本来解决：

  • 已修复的版本有：0.11.0.1,1.0.0。

ps：小版本里选最新

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

回复
回答于 2年前
半兽人
起风了 -> 半兽人 2年前

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

0 0 回复
半兽人 -> 起风了 2年前

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

0 0 回复
起风了 -> 半兽人 2年前

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

0 0 回复
半兽人 -> 起风了 2年前

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

0 0 回复
你的答案

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

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