=================
== Time Stream ==
=================
一个小学生

RocketMQ中Consumer的rebalance

RocketMQ

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

参考