Storm Ack框架筆記

  Storm利用Acker Bolt節點跟蹤消息,當Spout發送出去的消息以及這些消息所衍生出來的消息均被處理後,Spout將受到對應於該消息的Ack。實現要點:   1、Storm中每條發送出去的消息都會對應一個隨機的消息ID。   2、Spout發送消息後,將向Acker Bolt發送一條消息,該消息內容爲<RootId,消息ID>,Acker bolt將爲該消息創建一條跟蹤項。   3、
相關文章
相關標籤/搜索