返回到文章

采纳

编辑于

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

kafka

生产者配置为

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