storm 消息處理保證機制

Storm保證spout發出來的每條消息都會被完全的處理。這篇文章描述了Storm是如何實現這一保證機制的以及作爲一個storm的使用者我們如何從storm的這種可靠性中獲益。 消息被"完整處理"的含義 由spout發出來的一個tuple（元組）會觸發下游更多的tuple的生成。讓我們看你這個流單詞計數的topology: [java]  view plain  copy TopologyBuil

>>阅读原文<<