生产者配置为 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
你是在压测?积压太多,到期还没发出去。
对 但是我们线上服务就有这么多
如果服务器没有出现瓶颈,就增大客户端的缓存池和等待时间。具体可参照客户端配置章节
你的答案