GitHub user LiuCen82 added a comment to the discussion: rocketmq-client-java
5.0.7如何开启广播模式
我使用命令 bin/mqadmin updateSubGroup -d true -g myClientGroup -n
192.168.120.107:9876 -c DefaultCluster
并获得了 create subscription group to 192.168.120.107:10911 success.
SubscriptionGroupConfig{groupName=myClientGroup, consumeEnable=true,
consumeFromMinEnable=false, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
的返回，可是我的ConsumerGroup还是把消息平均分给了组内的两个PushConsumer实例。
请问我应该如何修改配置才能做到消费者组的广播模式？
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/775#discussioncomment-9857891
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
