这是一个关于风暴的最大喷口如何工作的问题.我目前有一个读取文件的spout并为文件中的每一行发出一个元组(我知道storm不是处理文件的最佳解决方案,但我没有选择这个问题).我将max spout pending设置为50k,以限制要处理的拓扑中有多少元组.但是,我看到这个数字在拓扑中没有任何影响.我看到每次都会发出文件中的所有记录.我猜这可能是因为我在nextTuple方法中有一个循环,它发出文件中的所有记录.所以我的问题是暴风雨是否会在达到最大喷口待处时停止调用喷口任务的下一个元组？这是否意味着我每次调用nextTuple时都应该只发出一个元组？