拓撲會通過 Nimbus 分發給 supervisor, 那麼 Nimbus 內部是怎麼操作的? 這裡以本地模式為例, 對拓撲的提交過程做一個分析. 參考資料: 理解storm拓撲並行度 疑問:

本篇主要介紹task的建立與執行過程 文章開頭, 先丟擲一些疑問: 為什麼TaskTransfer、TaskReceiver 要在初始化Task的時候建立, 為什麼不在Worker裡直接建立好?

Ack 機制是 storm 能夠保證訊息至少被處理一次（at least once）的核心，從而保證訊息不丟失。在 topology 有向無環圖中，spout 向 bolt 發射訊息，上游 bolt 也會向下

上一篇我們分析了 supervisor 節點的啟動和執行過程，提及到 supervisor 的核心工作就是基於 ZK 從 nimbus 節點領取分配給它的任務，並啟動 worker 執行。一個 worker 就

Supervisor 節點可以理解為單機任務排程器，它負責監聽 nimbus 節點的任務資源分配，啟動相應的 worker 程序執行 nimbus 分配給當前節點的任務，同時監測 worker 的執行狀態，一旦

本篇我們一起分析一下 nimbus 節點的啟動和執行機制。Nimbus 節點是 storm 叢集的排程者和管理者，它是叢集與使用者互動的視窗，負責 topology 任務的分配、啟動和執行，也管理著叢集中所有的

在具體開始分析 storm 叢集的啟動和執行機制之前，我們先來看一下基礎的執行緒模型，在整個 storm 的實現中有很多地方用到它，所以將其單獨拎出來先分析說明一下，後面看到相應的類就大致知道其內在的執行過程啦

上一篇我們分析了 topology 構建和提交過程在客戶端的邏輯，並最終通過submitTopology 方法向 storm 叢集的 nimbus 節點提交任務。Nimbus 以 Thrift RPC