storm的ack原理

 Storm的ack機制 Ack機制基本知識 (1)爲了保證消息處理過程中的可靠性,storm使用了ack機制。storm會專門啓動若干acker線程,來追蹤tuple的處理過程。acker線程數量可以設置。 (2)每一個Tuple在Spout中生成的時候,都會分配一個64位的messageId。通過對messageId進行哈希我們可以知道要對哪個acker線程發送消息來通知它監聽這個Tuple。
相關文章
相關標籤/搜索