RocketMQ: Wie werden die Warteschlangen eines Themas den Hauptbrokern zugeordnet?

Question

Wie ich weiß, ist in RocketMq eine "Warteschlange" ähnlich wie eine "Partition" in Kafka. Ein Thema hat mehrere Warteschlangen, hat auch mehrere Broker (Master und Slave).

Aber wie sind die Warteschlangen den Mastern zugeordnet?

Zum Beispiel, wenn ich ein Thema mit 3 Warteschlangen und 3 Master habe. Die 3 Warteschlangen verteilen sich auf die 3 Master? oder jeder Master hat 3 Warteschlangen?

Answer 1

Sie können die Warteschlangennummern angeben Wenn Sie Thema erstellen:

sh mqadmin updateTopic -h 
usage: mqadmin updateTopic [-b <arg>] [-c <arg>] [-h] [-n <arg>] [-o <arg>] [-p <arg>] [-r <arg>] [-s <arg>] 
     -t <arg> [-u <arg>] [-w <arg>] 
-b,--brokerAddr <arg>  create topic to which broker 
-c,--clusterName <arg>  create topic to which cluster 
-h,--help     Print help 
-n,--namesrvAddr <arg>  Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876 
-o,--order <arg>   set topic's order(true|false 
-p,--perm <arg>    set topic's permission(2|4|6), intro[2:W 4:R; 6:RW] 
-r,--readQueueNums <arg> set read queue nums 
-s,--hasUnitSub <arg>  has unit sub (true|false 
-t,--topic <arg>   topic name 
-u,--unit <arg>    is unit topic (true|false 
-w,--writeQueueNums <arg> set write queue nums 

Das bedeutet, dass Sie die Queue-Zahlen in einem Makler oder Cluster entscheiden kann. Weitere Details entnehmen Sie bitte here.