Storm Ack框架笔记

　　Storm利用Acker Bolt节点跟踪消息，当Spout发送出去的消息以及这些消息所衍生出来的消息均被处理后，Spout将受到对应于该消息的Ack。实现要点： 　　1、Storm中每条发送出去的消息都会对应一个随机的消息ID。 　　2、Spout发送消息后，将向Acker Bolt发送一条消息，该消息内容为<RootId,消息ID>，Acker bolt将为该消息创建一条跟踪项。 　　3、

>>阅读原文<<