RocketMQ的rebalance学习。

rebalance场景：

• 消费者发送心跳到Broker，Broker端发现有新的消费者进来或者新增了topic订阅信息或者删除了topic订阅信息，Broker会通知所有消费者NOTIFY_CONSUMER_IDS_CHANGED，消费者收到请求后会立刻进行rebalance：MQClientInstance#rebalanceImmediately
• DefaultMQPushConsumerImpl#start最后会调用MQClientInstance#rebalanceImmediately开始rebaplace
• RebalanceService每隔20秒会执行一次rebalance

draw io源文件RocketMQ中Consumer的rebalance.drawio

参考