You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@rocketmq.apache.org by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/10/25 04:22:17 UTC
Which broker the msg will be sent when partitioned by SelectMessageQueueByHash
Cluster mode, two brokers broker-a and broker-b. The topic queue number is set to 8.
For one specified msg, hash%8 is 2, the message will be sent queue2.
Both broker-a and broker-b has queue2. Which broker the msg will be sent to?
Thanks,
Lei
wanglei2@geekplus.com.cn
Re: Re: Which broker the msg will be sent when partitioned by SelectMessageQueueByHash
Posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn>.
So if there's two broker, topic queue set to 8, the mqs.size() is 16. Am i right?
Thanks,
Le
wanglei2@geekplus.com.cn
From: heng du
Date: 2019-10-25 13:35
To: users
Subject: Re: Which broker the msg will be sent when partitioned by SelectMessageQueueByHash
QueueSelector will give you list<MessageQueue>, and MessageQueue has the 'brokerName' attribute. you can use it.
wanglei2@geekplus.com.cn <wa...@geekplus.com.cn> 于2019年10月25日周五 下午12:22写道:
Cluster mode, two brokers broker-a and broker-b. The topic queue number is set to 8.
For one specified msg, hash%8 is 2, the message will be sent queue2.
Both broker-a and broker-b has queue2. Which broker the msg will be sent to?
Thanks,
Lei
wanglei2@geekplus.com.cn
Re: Which broker the msg will be sent when partitioned by SelectMessageQueueByHash
Posted by heng du <du...@gmail.com>.
QueueSelector will give you list<MessageQueue>, and MessageQueue has the
'brokerName' attribute. you can use it.
[image: image.png]
wanglei2@geekplus.com.cn <wa...@geekplus.com.cn> 于2019年10月25日周五
下午12:22写道:
>
> Cluster mode, two brokers broker-a and broker-b. The topic queue number
> is set to 8.
>
> For one specified msg, hash%8 is 2, the message will be sent queue2.
> Both broker-a and broker-b has queue2. Which broker the msg will be sent
> to?
>
> Thanks,
> Lei
>
> ------------------------------
> wanglei2@geekplus.com.cn
>