生产者经验

如何提高生产者吞吐量

常见的几个参数

• batch.size:批次大小,默认16k
• linger.ms:等待时间,修改为5-100ms

• compression.type:压缩snappy;将数据压缩
• RecordAccumulator:缓冲区大小,修改为64m;增加缓冲区大小