storm的ack原理

 Storm的ack机制 Ack机制基本知识 (1)为了保证消息处理过程中的可靠性,storm使用了ack机制。storm会专门启动若干acker线程,来追踪tuple的处理过程。acker线程数量可以设置。 (2)每一个Tuple在Spout中生成的时候,都会分配一个64位的messageId。通过对messageId进行哈希我们可以知道要对哪个acker线程发送消息来通知它监听这个Tuple。
相关文章
相关标签/搜索