Apache Storm 中的 Spout 节流

【问题标题】：Spout throttling in Apache StormApache Storm 中的 Spout 节流
【发布时间】：2016-02-27 23:37:52
【问题描述】：

我了解max.spout.pending 是一种通过acking-enabled 实现背压的简单方法。我想了解一下，既然已经实现了背压，我们还需要max.spout.pending 来限制喷口吗？

谢谢！

【问题讨论】：

你能指出提到这种自动背压实现的页面吗？
不需要，开启这个配置即可topology.backpressure.enable: true

【解决方案1】：

从Storm 1.0.0 开始，提供背压自动化，并且可以通过高/低水位线 (disruptor.highwatermark/disruptor.lowwatermark) 来配置 Bolt 的接收器缓冲区和 Bolt 的缓冲区大小 (executor.'receive/send'.buffer.size)。
因此，spout 根据水印限制/释放元组到螺栓。

欲了解更多信息，请参阅：http://storm.apache.org/2016/04/12/storm100-released.html

【讨论】：