kafka生产者发送消息，时间久了会出现Expiring 315 record(s) for test-0: 41261 ms has passed since last append

稻草人 发表于: 2018-08-03 最后更新时间: 2018-08-04 16:47:56 9,520 游览

生产者配置为

linger.ms=1
batch.size=16384
buffer.memory=33554432
retries=1

kafka服务器是3台机器的集群

生产时间久了就会爆出

Expiring 315 record(s) for XXX: 41261 ms has passed since last append

kafka

发表于 2018-08-03

稻草人

添加评论

你是在压测？积压太多，到期还没发出去。

回答于 5年前

半兽人

稻草人 -> 半兽人 5年前

对但是我们线上服务就有这么多

半兽人 -> 稻草人 5年前

如果服务器没有出现瓶颈，就增大客户端的缓存池和等待时间。具体可参照客户端配置章节

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

提问