Storm的ack原理和使用

Storm的ack原理 經過Ack機制,spout發送出去的每一條消息,均可以肯定是被成功處理或失敗處理, 從而可讓開發者採起動做。好比在Meta中,成功被處理,便可更新偏移量,當失敗時,重複發送數據。 所以,經過Ack機制,很容易作到保證全部數據均被處理,一條都不漏。 另外須要注意的,當spout觸發fail動做時,不會自動重發失敗的tuple,須要spout本身從新獲取數據,手動從新再發送一次
相關文章
相關標籤/搜索