Storm总结

spout把AMQP队列中消息填充到storm中。队列中的每个消息被作为一个Tuple提交。消息将会被确定或拒绝,一旦这拓扑完全处理了(正确或者失败)相应的Tuple。【如果需要确保所有的信息被可靠性的处理,要令AMQPSpout从<em>not</em>设为‘exclusive’或‘auto-delete’的队列中消费,否则,如果spout任务崩溃或者重启,这个队列就会被删除并丢弃其中所有的消息
相关文章
相关标签/搜索