可调参数

  • batch.size：批次大小，默认16k
  • linger.ms：等待时间，修改为5~100ms
  • compression.type：压缩类型，一般选择snappy
  • RecordAccumulator：缓冲区大小，修改为64M

注意

这些参数的修改需要根据实际情况进行调整。