ConsumeMessageOrderlyService消费消息时，对processQueue的consumeLock加读锁的作用是什么 #8114
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
{{ message }}
-
看网上的资料都说加锁是为了防止当前consumer还在消费，且没有提交位移时发生了重平衡，正在消费的messagequeue被分配给了其他消费者，导致重复消费。但是通过阅读源码发现，在发生锁争抢时，processQueue是dropped状态，即使加了读锁保证消费完了才继续重分配，消费位移还是无法被提交。还是我理解有误？
ConsumeMessageOrderlyService内部类ConsumeRequest#run的部分代码
顺序消费的重平衡逻辑实现类RebalancePushImpl里的部分代码
Beta Was this translation helpful? Give feedback.
All reactions