本文介绍了如何设置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的每秒消息速率?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!