storm的ack消息不丟失機制

1:ack是什麼 ack 機制是storm整個技術體系中非常閃亮的一個創新點。 通過Ack機制,spout發送出去的每一條消息,都可以確定是被成功處理或失敗處理, 從而可以讓開發者採取動作。比如在Meta中,成功被處理,即可更新偏移量,當失敗時,重複發送數據。 因此,通過Ack機制,很容易做到保證所有數據均被處理,一條都不漏。 另外需要注意的,當spout觸發fail動作時,不會自動重發失敗的tu
相關文章
相關標籤/搜索