有个rocketmq client模块的代码的问题请教一下

有个rocketmq client模块的代码的问题请教一下 （详细描述在这里 https://github.com/apache/rocketmq/discussions/8114 ）。ConsumeMessageOrderlyService的内部类ConsumeRequest#run方法，在执行messageListener的消费方法前加了consumeLock.readLock，这个加锁操作网上说是为了防止消费时发生重平衡，将正在消费的队列重分配给其他consumer，从而减少重复消费的可能性。但是我发现消费位移因为processQueue状态在发生锁冲突前就已经是dropped，消费位移也因此无法提交到broker或持久化下来。那重平衡完成后，队列分配给其他消费者，不还是出现了重复消费，我理解并没有降低重复消费概率。