1. 可能是你没有配置我们给你的消费组,而是自己自定义的消费组。我们后台消费组做了限制,只能购用我们给你的消费组才能消费数据;
2. 可能是你worker启了多个消费者,一个worker最多只有一个消费者;
3. 由于我们只能给你一个消费组,所以你如果需要启多个消费者的话,你每个消费者都需要订阅所有的topic;
4. Jstorm集群中我们以环境变量的形式配置了Rocketmq的nameserver的地址,所以选手代码中不需要显示用setNamesrvAddr去指定地址,如之前有显示指定地址提交代码时记得将setNamesrvAddr删除;
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。