本文介绍了如何设置Kafka Producer的每秒消息速率?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我正在读取一个csv文件,并将此输入的行提供给我的Kafka Producer.现在我希望我的Kafka Producer以每秒100条消息的速度产生消息.

I am reading a csv file and giving the rows of this input to my Kafka Producer. now I want my Kafka Producer to produce messages at a rate of 100 messages per second.

推荐答案

看看Kafka Producer的 linger.ms batch.size 属性.您必须相应地调整这些属性才能获得所需的速率.

Take a look at linger.ms and batch.size properties of Kafka Producer.You have to adjust these properties correspondingly to get desired rate.

这篇关于如何设置Kafka Producer的每秒消息速率?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

09-09 10:48