[GitHub] [rocketmq] lizhanhui commented on issue #4828: How to set the message load balance consumption in RocketMQ with more than one client?

[GitBox <gi...@apache.org>]

lizhanhui commented on issue #4828:
URL: https://github.com/apache/rocketmq/issues/4828#issuecomment-1217382918

   Consumers of the same consumer group are expected to have exactly the same subscriptions, aka, the same set of topics with the same filter expressions. 
   
   Now we are having two major clients 4.x and 5.x.
   For 4.x, load-balancing is conducted at the granularity of **message-queue**. For FIFO messages where messages are published to queues of their choice, it would be possible that some queues have more messages than others. As a result, some consumer clients are more loaded than others. Note, non-FIFO messages may also go through a queue-selector when publishing, skew in load is also possible. Use consumerProgress command in the admin toolset to inspect if this is the case.
   
   For [5.x](https://github.com/apache/rocketmq-clients), load-balancing is done at a finer granularity, aka loads are averaged at the message-group tier(for standard messages, each one is a distinct message group, conceptually). You are expecting to have very fair loads among all consumer clients regardless of the publishing approach. 
   
    


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org