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