关于storm是如何保证消息不丢失的问题看的云里雾里的
比如说这两个场景
SpoutA发消息到BoltB,BoltB把SpoutA的消息切成10份,发给BoltC
SpoutA发消息到BoltB,BoltB收集10条SpoutA的消息后,发给BoltC
什么时候会产生新的tuple id?什么时候会传给acker进行校验?acker里边的校验值都是如何变化的?什么时候会调用ack方法和fail方法?storm是如何保证这两个场景的消息不丢失的呢?
关于storm是如何保证消息不丢失的问题看的云里雾里的
比如说这两个场景
SpoutA发消息到BoltB,BoltB把SpoutA的消息切成10份,发给BoltC
SpoutA发消息到BoltB,BoltB收集10条SpoutA的消息后,发给BoltC
什么时候会产生新的tuple id?什么时候会传给acker进行校验?acker里边的校验值都是如何变化的?什么时候会调用ack方法和fail方法?storm是如何保证这两个场景的消息不丢失的呢?