You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by "z521598 (via GitHub)" <gi...@apache.org> on 2023/07/16 14:16:14 UTC
[GitHub] [rocketmq-clients] z521598 created a discussion: Rocket5.0.5 Java客户端如何设置广播消费
GitHub user z521598 created a discussion: Rocket5.0.5 Java客户端如何设置广播消费
根据[5.x的文档](https://rocketmq.apache.org/zh/docs/featureBehavior/08consumerloadbalance#%E5%B9%BF%E6%92%AD%E6%B6%88%E8%B4%B9%E5%92%8C%E5%85%B1%E4%BA%AB%E6%B6%88%E8%B4%B9)，看意思是 通过不同的消费者组，不同消费者设置不同的消费者名字，到达广播消费的效果。
不知道理解的对不对，Rocket5.0.5怎么像4.x一样设置广播消费呢？
consumer.setMessageModel(MessageModel.BROADCASTING);
GitHub link: https://github.com/apache/rocketmq-clients/discussions/572
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
[GitHub] [rocketmq-clients] francisoliverlee added a comment to the discussion: Rocket5.0.5 Java客户端如何设置广播消费
Posted by "francisoliverlee (via GitHub)" <gi...@apache.org>.
GitHub user francisoliverlee added a comment to the discussion: Rocket5.0.5 Java客户端如何设置广播消费
you are right , check the comment <a href="https://github.com/apache/rocketmq-clients/blob/973c9580d4ed1b4cf31f9f7df1b290d22b50c6a0/java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/PushConsumer.java#L47C1-L56">here</a>
GitHub link: https://github.com/apache/rocketmq-clients/discussions/572#discussioncomment-6932270
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] Rocket5.0.5 Java客户端如何设置广播消费 [rocketmq-clients]
Posted by "AI1186780944 (via GitHub)" <gi...@apache.org>.
GitHub user AI1186780944 added a comment to the discussion: Rocket5.0.5 Java客户端如何设置广播消费
> you are right , check the comment [here](https://github.com/apache/rocketmq-clients/blob/973c9580d4ed1b4cf31f9f7df1b290d22b50c6a0/java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/PushConsumer.java#L47C1-L56)
请问要实现4.x版本中的那种广播模式应该如何处理？比如有一个用于监听缓存变化的topic。我希望同一个消费者分组中所有的消费者均能获取到这个topic的消息，用于更新本地缓存的数据。这种需求应该如何处理？我看到你给的文档链接里的示意了，但是这并不能解决相应的问题。毕竟同一个消费者分组其group应该是相同的才对。对于一个代码相同的集群，也不能每一个消费者实例设置的不同的group来处理逻辑相同的业务吧？
GitHub link: https://github.com/apache/rocketmq-clients/discussions/572#discussioncomment-7948005
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org