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 dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org

Reply via email to