storm的可靠性如何实现

ack机制与fail机制

Spout创建一个新的Tuple时,会调用ack来表明这个消息被完全处理;Bolt在处理Tuple后,无论成功还是失败都会发一个消息通知ack;ack会找到发射该Tuple的Spout,回调其ack或fail。

标签: ack、tuple、spout、fail、会发、面试
猜你感兴趣的圈子:
拜托了冰箱
  • 回复
隐藏