storm是如何保证消息不丢失的

关于storm是如何保证消息不丢失的问题看的云里雾里的

比如说这两个场景

  • SpoutA发消息到BoltB,BoltB把SpoutA的消息切成10份,发给BoltC

  • SpoutA发消息到BoltB,BoltB收集10条SpoutA的消息后,发给BoltC

什么时候会产生新的tuple id?什么时候会传给acker进行校验?acker里边的校验值都是如何变化的?什么时候会调用ack方法和fail方法?storm是如何保证这两个场景的消息不丢失的呢?

阅读 3.3k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
logo
101 新手上路
子站问答
访问
宣传栏