Storm總結

spout把AMQP隊列中消息填充到storm中。隊列中的每個消息被作爲一個Tuple提交。消息將會被確定或拒絕,一旦這拓撲完全處理了(正確或者失敗)相應的Tuple。【如果需要確保所有的信息被可靠性的處理,要令AMQPSpout從<em>not</em>設爲‘exclusive’或‘auto-delete’的隊列中消費,否則,如果spout任務崩潰或者重啓,這個隊列就會被刪除並丟棄其中所有的消息
相關文章
相關標籤/搜索