RocketMQ 的Rebalance机制，消息重复问题

文章目录

• 所谓Rebalance到底在解决什么问题
• Rebalance具体是如何决定分配的数量的
• Rebalance是怎么对多Topic做分配
• Rebalance什么时候触发
• Rebalance可能会带来消息的重复消费

集群模式下，每个消费者实例会被分配到若干条队列。正因为消费者拿到了明确的队列，所以它们才能针对对应的队列做循环拉取消息的处理，以下是消费者客户端和broker通信的部分代码，可以看到通信的参数里有一个重要的参数，就是queueId

 PullMessageRequestHeader requestHeader = new PullMessageRequestHeader();