2019獨角獸企業重金招聘Python工程師標準>>>

1、https://issues.apache.org/jira/browse/STORM-886

????? https://github.com/apache/storm/pull/700

storm1.0.0之前 Spout tuples 不使用message id， TOPOLOGY_MAX_SPOUT_PENDING是不生效的。

即之適用ack模式拓撲

新的反壓機制

• worker executor的接收隊列大于高水位，通知反壓線程?
• worker反壓線程通知zookeeper，executor繁忙事件?
• 所有worker監聽zookeeper executor繁忙的事件?
• worker spouts降低發送tuple速度?

## 反壓總開關 topology.backpressure.enable: true

默認為false，只需要設置這里即可，可以適用任意拓撲。

轉載于:https://my.oschina.net/chuibilong/blog/865258

與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的Storm反压机制的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。