RocketMQ 知识梳理——Rebalance（rocketmq原理及解析）

问：如果某个消费者没有收到Rebalance通知怎么办？

答：通过定时任务保证Rebalance的执行，进行兜底。

问：Rebalance过程中，如何保证分配前的消费者和分配后的消费者避免重复消费？

答：Rebalance真进行重排，会涉及到drop当前分配、同步消费进度等操作，这几个动作比较重，所以可能会存在不一致，导致重新消费，所以消费端一定要做好幂等处理。

问：Rebalance的触发时机有哪些？

答：第一，启动时立即触发；第二，存在一个定时任务兜底；第三，消费者停止服务时；第四，队列数量变更时，其中第一和第三本质上是消费者数量变更，可以合并成一个。

问：Rebalance的流程大致是如何的？

答：第一步，获取Topic信息，消费组信息、队列信息；第二步，根据客户端配置的负载均衡策略进行Rebalance，所有操作都在消费组下各自的消费者本地进行分配。