BurningCN commented on issue #4451: URL: https://github.com/apache/rocketmq/issues/4451#issuecomment-1158435866
> 拉取数据前需要rebalance，rebalance之后才能拉取数据,也就是说在拉取消息之前有已经锁定了，调用了processQueue.setLocked(true)方法，在消费数据时自然就不会延迟。这个有延迟的定时任务是周期性去broker端锁定，防止锁定过期 最上面的截图，顺序消费模式，第一次在rebalance的时候会执行`this.lock(mq)`，但是无法置`processQueue.setLocked(true)`，因为取不到`processQueue`（`processQueue`的存入是在`this.lock(mq)`之后的） -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
