rocketmq consumer负载均衡策略

服务现象:

连续生产4条消息,都是同一个消费者消费。

解释:

当前服务一个topic设置16个queue,producer生产消息,轮流向各个queue写入,2个consumer各自接收8个queue的消息,所以可能连续写入几个消息都是同一个consumer消费的。

topic queue写入规则

DefaultMQPushConsumeril

DefaultMQPullConsumeril

节选自:《rocketmq实战与原理解析》

发表新评论