Why need to persist twice offset when rebalancing?
The source code is RebalancePushImpl#removeUnnecessaryMessageQueue.
In my opinion, just persist it once after locking it.
The source code is RebalancePushImpl#removeUnnecessaryMessageQueue.
In my opinion, just persist it once after locking it.