参考答案
- 增加线程
- 提高 batch.size
- 增加更多 producer 实例
- 增加 partition 数
- 设置 acks=-1 时,如果延迟增大:可以增大 num.replica.fetchers(follower 同步数据的线程数)来调解
- 跨数据中心的传输:增加 socket 缓冲区设置以及 OS tcp 缓冲区设置
以上,是 Kafka 面试题【Kafka producer如何优化打入速度】的参考答案。
输出,是最好的学习方法。
欢迎在评论区留下你的问题、笔记或知识点补充~
—end—