3
条回答
写回答
写回答
-
Rejstorm ack机制问题这个就是数据的分发和聚合相关的内容
1. 需要在topologyBuilder哪里进行配置，grouping的方式决定了该IComponent如何订阅上层的IComponent
2.
2.1 收到几个ack，需要看你emit的时候有没有锚定tuple，一般来说是需要收到Tuple Tree上所有组件的ack才算成功不会调用fail，超时也会fail
2.2 会2016-06-23 16:48:49赞同 展开评论 打赏 -
回 1楼玄弟的帖子我理解的 grouping 方式，是一个bolt 的tuple 是如何流到下一个同类的tuple的，比如说
builder.setBolt(MINIUTETBTMTRADEBOLT_ID,miniuteTbTmTradeBolt,1).shuffleGrouping(PAYMENTMESSAGE_DESERIALIZE_BOLT_ID);
我认为只针对下游同类的tuple 有效，难道是说针对下游所有的bolt ？ 是我理解错了么？2016-06-23 10:55:45赞同 展开评论 打赏 -
1. 这个是由你来决定的；看你用什么grouping方式，你去了解下。
2. 如果你开了acker机制，一条消息被成功处理之后，会回调acker函数；如果在规定时间内消息超时，会回调fail函数；
2016-06-23 10:48:55赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
