11
2020
08

kafka producer如何优化打入速度

增加线程


提高 batch.size


增加更多 producer 实例


增加 partition 数


设置 acks=-1 时,如果延迟增大:可以增大 num.replica.fetchers(follower 同步数据的线程数)来调解;


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

« 上一篇 下一篇 »

发表评论:

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。