You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/06/17 02:44:33 UTC

[GitHub] [rocketmq] ni-ze commented on issue #4451: Question about this.lock(mq) in updateProcessQueueTableInRebalance method

ni-ze commented on issue #4451:
URL: https://github.com/apache/rocketmq/issues/4451#issuecomment-1158428169

   拉取数据前需要rebalance，rebalance之后才能拉取数据,也就是说在拉取消息之前有已经锁定了，调用了processQueue.setLocked(true)方法，在消费数据时自然就不会延迟。这个有延迟的定时任务是周期性去broker端锁定，防止锁定过期


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org