kafka producer如何优化打入速度？

• 增加线程

• 提高 batch.size

• 增加更多 producer 实例

• 增加 partition 数

• 设置 acks=-1 时，如果延迟增大：可以增大 num.replica.fetchers（follower 同步数据的线程数）来调解；

• 跨数据中心的传输：增加 socket 缓冲区设置以及 OS tcp 缓冲区设置。

原文：https://www.cnblogs.com/programb/p/12906759.html