我们正在以大约9000条记录/秒的速度向kafka集群中写入消息，有时我们会看到生产者性能显著下降，然后再也无法恢复。当这种情况发生时，我们会看到以下错误“无法在超时内分配缓冲区”。下面是流程运行良好和达到不良状态时所采用的jmx producer度量。“等待线程”指标非常高，当进程降级时，任何输入都将受到赞赏。
生产者参数为

batch.size=1000000
linger.ms=30000
acks=-1
metadata.fetch.timeout.ms=1000
compression.type=none
max.request.size=10000000

在缓冲区完全可用时，错误为“org.apache.kafka.common.errors.timeoutexception:未能在配置的最大阻塞时间内分配内存”