rocketmq问题
consumer接收完数据后，过几秒又会接收同样的数据，只要consumer不停下来，就会不断地接收重复数据，而且会接收我没有订阅的topic的数据，这是什么情况
展开
收起
2
条回答
写回答
写回答
-
回 1楼尘央的帖子就是我先向队列发送了100000条数据，然后启动consumer接收，接收完这100000条数据后，由于consumer没有停，几秒后，consummer又开始接收才的最后25条数据，接收完隔几秒又开始接收，就这样循环。有时候你没有给队列发数据，但是consummer启动之后却能接收到上次已经接受过的数据，甚至不同topic的消息也能接收到。数据接收一次不是就失效了么？为啥还能再次接收？-------------------------
回 3楼尘央的帖子请问竞赛时rocketmq中每个topic有几个队列，还有就是在nextTuple中启动DefaultMQPushConsumer，由于要不停地调用nextTuple，那不是DefaultMQPushConsumer不停地启动，就会报异常怎么办2016-06-04 21:22:14赞同 展开评论 打赏 -
I like to program and write stuff, making things a reality always make me excited. Now, I am a Apache committer.。。再多提供一些信息吧。
-------------------------
可以贴下你的代码。
有可能你上次测试的时候还剩下一些数据没被消费完，本次测试消费过来了。另外，mq是有可能消息重复的。-------------------------
回 4楼(wishworld) 的帖子topic应该有很多个队列，具体多少个还暂时未定，不必关注这些。
具体的编码细节需要你们自己来设计了。2016-06-04 19:50:39赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
