# producer.properties
linger.ms=5
batch.size=16384
delivery.timeout.ms=120000
request.timeout.ms=30000

发送端报 TimeoutException: Expiring 12 record(s) for order-event-3:30000 ms has passed since batch creation。这类现象通常不是突然出现的,往前翻半天日志能看到苗头。

追下去是这么回事:消息攒在客户端缓冲区里迟迟发不出去,常见于 broker 不可达、分区 leader 频繁切换,或者 linger.ms 与 batch.size 配得过大。

「Kafka 发送超时」改完先别急着全量,挑一台机器放半天,真有问题这段时间就能看出来。同类问题如果隔一段时间又出现,多半是某个定时任务或重启流程把改动冲掉了。

把这次用到的命令存进笔记,比记住结论有用,换个环境还能照着走。改完隔一天再看一次,当场正常不代表能稳住。

测试环境和线上的差别,往往就在版本号和那几行被忽略的配置上。线上出问题先对时间点,跟发布、备份、任务执行的时刻排一排,能省掉一半功夫。

处理上按这个顺序:核对 delivery 与 request 两个超时参数的取值;确认目标分区的 leader 没有在反复切换;先把 linger.ms 调到 5 毫秒以内 排除攒批因素。

确认没问题再收工,发送回调里不再出现 TimeoutException,成功率回到百分之百。

作者 9823189