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
>