You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by "AI1186780944 (via GitHub)" <gi...@apache.org> on 2023/12/26 10:48:10 UTC

Re: [D] Rocket5.0.5 Java客户端如何设置广播消费 [rocketmq-clients]

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