RocketMQ监听queen负载均衡的流程
2021-05-07 17:18:54 0 举报RocketMQ监听queen负载均衡的流程
作者其他创作
大纲/内容
按分配策略来分配客户端所监听的queen
获取该topic下所有的客户端id、并排序
集群模式
移除缓存中不是该实例处理的queue
轮询该实例订阅的所有topic
广播模式
获取该topic下的queen集合
遍历topic 执行rebalance
消息消费模式
调用updateProcessQueueTableInRebalance更新
0 条评论
下一页
