Storm 从入门到精通 第二十二讲 Storm 批处理事务-原理详解

1.  批处理 对于容错机制，Storm通过一个系统级别的组件acker，结合xor校验机制判断一个tuple是否发送成功，进而spout可以重发该tuple ，保证一个tuple在出错的情况下至少被重发一次。 但是在需要精确统计tuple的数量如销售金额场景时，希望每个tuple”被且仅被处理一次” 。 Storm 0.7.0引入了Transnational Topology, 它可以保证每个t

>>阅读原文<<