| linger.ms | 批次等待时间,默认 0(有记录即发) |
|---|---|
| batch.size | 单分区单批字节数上限,默认 16KB |
| buffer.memory | 生产者总缓冲,默认 32MB,写满会阻塞或抛异常 |
吞吐优先配置示例
吞吐优先配置示例
linger.ms=20
batch.size=65536
compression.type=lz4
buffer.memory=67108864缓冲区不足时 send() 会阻塞到 max.block.ms 超时,异常信息是 TimeoutException: Failed to allocate memory。