文章目录
- 所谓Rebalance到底在解决什么问题
- Rebalance具体是如何决定分配的数量的
- Rebalance是怎么对多Topic做分配
- Rebalance什么时候触发
- Rebalance可能会带来消息的重复消费
集群模式下，每个消费者实例会被分配到若干条队列。正因为消费者拿到了明确的队列，所以它们才能针对对应的队列做循环拉取消息的处理，以下是消费者客户端和broker通信的部分代码，可以看到通信的参数里有一个重要的参数，就是queueId
代码语言：javascript复制 PullMessageRequestHeader requestHeader = new PullMessageRequestHeader();
