同一个主题下的消费队列和消费者分配
1、先对消费队列和消费者排序 2、消费者类似于页数、消费队列类似于所有记录数 一个消费者所消费的消费队列 类似第5页包含的记录数 3、消息队列分配策略算法(默认为:消息队列的平均分配算法)
- 过滤分配到的消息的队列集合
将分配到的消息队列集合与现有的集合做对比 过滤掉失效的
- 红色
表示与分配到的消息队列集合互不包含
剔除无效数据
- 绿色
表示与分配到的消息队列集合的交集
处理过期数据
- 白色
表示新增的待消费的队列
处理新增数据
向broker拉取消息