Storm消息可靠性保证机制ack与fail原理

一.Storm spout的nextTuple以及bolt的execute Storm的API非常丰富,但是记住,本文介绍的ACK机制需要特殊的支持。也就是说,本文所说的ACK的机制只是Storm的一种可选机制,你完全可以无视它去选择一种轻量的无确认的Best effort方式去使用Storm,本文之所以单独介绍ACK机制,是因为其优雅。 在编写spout的nextTuple时,最终你必须要emi
相关文章
相关标签/搜索