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