rocketmq问题
回 1楼尘央的帖子
就是我先向队列发送了100000条数据,然后启动consumer接收,接收完这100000条数据后,由于consumer没有停,几秒后,consummer又开始接收才的最后25条数据,接收完隔几秒又开始接收,就这样循环。有时候你没有给队列发数据,但是consummer启动之后却能接收到上次已经接受过的数据,甚至不同topic的消息也能接收到。数据接收一次不是就失效了么?为啥还能再次接收?
-------------------------
回 3楼尘央的帖子
请问竞赛时rocketmq中每个topic有几个队列,还有就是在nextTuple中启动DefaultMQPushConsumer,由于要不停地调用nextTuple,那不是DefaultMQPushConsumer不停地启动,就会报异常怎么办
赞0
踩0