Storm的acker确认机制

 Storm的acker消息确认机制...        ack/fail消息确认机制(确保一个tuple被完全处理)        在spout中发射tuple的时候需要同时发送messageid,这样才相当于开启了消息确认机制         如果你的topology里面的tuple比较多的话, 那么把acker的数量设置多一点,效率会高一点。        通过config.setNumAc
相关文章
相关标签/搜索