You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/08/16 15:39:46 UTC
[GitHub] [rocketmq] PEIYANGXINQU opened a new issue, #4828: How to set the message load balance consumption in RocketMQ with more than one client?
PEIYANGXINQU opened a new issue, #4828:
URL: https://github.com/apache/rocketmq/issues/4828
There are two Rocket MQ clients, both of which belong to the same consumption group. How to set the message load balance consumption? It seems that one client has more consumption messages and the other has less, and the consumption is uneven.
--
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.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] PEIYANGXINQU commented on issue #4828: How to set the message load balance consumption in RocketMQ with more than one client?
Posted by GitBox <gi...@apache.org>.
PEIYANGXINQU commented on issue #4828:
URL: https://github.com/apache/rocketmq/issues/4828#issuecomment-1217383090
收到，谢谢！
--
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
[GitHub] [rocketmq] lizhanhui commented on issue #4828: How to set the message load balance consumption in RocketMQ with more than one client?
Posted by GitBox <gi...@apache.org>.
lizhanhui commented on issue #4828:
URL: https://github.com/apache/rocketmq/issues/4828#issuecomment-1217385910
@PEIYANGXINQU I would close this issue as your concern should have been clarified. Feel free to re-open it if you had follow-up ones.
--
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
[GitHub] [rocketmq] lizhanhui commented on issue #4828: How to set the message load balance consumption in RocketMQ with more than one client?
Posted by 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
[GitHub] [rocketmq] lizhanhui closed issue #4828: How to set the message load balance consumption in RocketMQ with more than one client?
Posted by GitBox <gi...@apache.org>.
lizhanhui closed issue #4828: How to set the message load balance consumption in RocketMQ with more than one client?
URL: https://github.com/apache/rocketmq/issues/4828
--
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