在Apache Storm中输入数据速率

Question

我正在从文件中读取文本数据并使用apache storm处理它以产生结果。我想尝试不同的输入数据速率。我想知道，在此设置中，如何更改apache storm中的输入数据速率。输入数据速率也是：

spout / Time发出的元组数

Answer 1

默认情况下，Storm会尽快将元组从喷口中拉出来。您可以通过以下几种设置与此进行互动：

topology.max.spout.pending定义在Storm将节流喷口并等待某些元组被激活之前可以向拓扑中发出多少元组。默认情况下，这是没有上限的。

topology.sleep.spout.wait.strategy.time.ms定义如果对nextTuple的调用没有产生输出，那么在spout上调用nextTuple之间Storm会暂停多少毫秒。默认为1毫秒。