Kafka9:提高生产者吞吐量

Kafka9:提高生产者吞吐量

1. 场景

notion image

2. 提高吞吐量

  • batch.size:批次大小,默认16k —>32k
  • linger.ms:等待时间,修改为5-100ms
  • compression.type:压缩snappy
  • RecordAccumulator:缓冲区大小,32m修改为64m