Storm的ACK機制與編碼實例

Storm爲了保證每條數據成功被處理,實現至少一次語義，經過Storm的ACK機制能夠對spout產生的每個tuple進行跟蹤;php tuple處理成功是指這個Tuple以及這個Tuple產生的全部子Tuple都被成功處理, 由每個處理bolt經過OutputCollector的方法ack(tuple)來告知storm當前bolt處理成功，最終調用spout的ack方法；html 處理失敗是指這

>>阅读原文<<