RocketMQ中如何设置两个客户端的消息负载均衡消耗？

【问题标题】：How to set the message load balance consumption in RocketMQ with two client?RocketMQ中如何设置两个客户端的消息负载均衡消耗？
【发布时间】：2023-02-01 11:14:41
【问题描述】：

有两个Rocket MQ客户端，都属于同一个消费组。消息负载均衡消费如何设置？貌似一个client消费消息多，一个client少，消费参差不齐。

【问题讨论】：

标签： rocketmq

【解决方案1】：

这个link 应该澄清你的问题。

【讨论】：

【解决方案2】：

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_JODIE_1");
consumer.subscribe("TopicTest", "*");

// MessageModel.CLUSTERING means all consumers consume load-balancely
// MessageModel.BROADCASTING means every consumer instance will consume all messages
consumer.setMessageModel(MessageModel.CLUSTERING);

【讨论】：