Storm的acker確認機制

 Storm的acker消息確認機制...        ack/fail消息確認機制(確保一個tuple被完全處理)        在spout中發射tuple的時候需要同時發送messageid,這樣才相當於開啓了消息確認機制         如果你的topology裏面的tuple比較多的話, 那麼把acker的數量設置多一點,效率會高一點。        通過config.setNumAc
相關文章
相關標籤/搜索