kafka生产者生产时报超时

黑山小妖 发表于: 2017-07-12   最后更新时间: 2021-11-15 10:02:10   16,875 游览

错误：

org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for alarminfo-7 due to 30078 ms has passed since batch creation plus linger time

配置是：

生产者代码：

kafka
发表于 2017-07-12
黑山小妖
添加评论

这个问题解决了吗

回复
回答于 3年前
n

先不谈你代码逻辑，首先确保你的集群可对外访问。

参考：
https://www.orchome.com/342
https://www.orchome.com/579

回复
回答于 6年前
半兽人
黑山小妖 -> 半兽人 6年前

可以访问，这个异常是偶尔发生的，大部分数据都就可以发到broker上

0 0 回复
半兽人 -> 黑山小妖 6年前

kafka什么版本，该错误在0.10.2.0已经修复了。

0 0 回复
半兽人 -> 黑山小妖 6年前

https://issues.apache.org/jira/browse/KAFKA-4557

0 0 回复
黑山小妖 -> 半兽人 6年前

我用的就是0.10.2.0

0 0 回复
黑山小妖 -> 半兽人 6年前

异常是发生在callback回调的时候

0 0 回复
半兽人 -> 黑山小妖 6年前

你的量大吗？

0 0 回复
黑山小妖 -> 半兽人 6年前

不大

0 0 回复
半兽人 -> 黑山小妖 6年前

那就很奇怪了，检查下客户端与kafka服务器之间的网络层面有没有主动阻断。关闭防火墙，一般公司会有这个现象。

查询下kafka服务器的网络监控和系统日志，还有kafka日志。看看是否有异常信息。

0 0 回复
沉睡千年 -> 半兽人 5年前

我现在也遇到这种情况，不知道是不是数据量大导致这个问题

0 0 回复
半兽人 -> 沉睡千年 5年前

https://www.orchome.com/472
先优化一些max参数，看看症状是否还出现。

0 0 回复
你的答案

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

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