storm 消息处理保证机制

Storm保证spout发出来的每条消息都会被完全的处理。这篇文章描述了Storm是如何实现这一保证机制的以及作为一个storm的使用者我们如何从storm的这种可靠性中获益。 消息被"完整处理"的含义 由spout发出来的一个tuple（元组）会触发下游更多的tuple的生成。让我们看你这个流单词计数的topology: [java]  view plain  copy TopologyBuil

>>阅读原文<<