RocketMQ事务消息这个tag 过滤逻辑。 是需要一个topic 申请多个消费者组吗?
比如 有两套环境一个topic, a 环境 生成 tag=a的消息, b环境 生成tag=b的消息
这两套环境都在消费同一个消费者组会有问题吗。 目前发现好像是消费不全。
RocketMQ的事务消息与Tag过滤逻辑是独立的。每个消费者组可以订阅多个Tag,但同一消费分组内不建议创建多个消费者。如果a环境和b环境都在同一个消费者组内消费同一个Topic,并且分别生成tag=a和tag=b的消息,这可能导致消息消费不全。
正确做法是创建两个不同的消费者组,每个组消费特定的Tag。这样,a环境的消费者组仅消费tag=a的消息,b环境的消费者组消费tag=b的消息,保证消息正确路由和完整消费。请检查您的消费者配置,确保每个环境使用独立的消费者组。可参考云消息队列 RocketMQ 版 消费者(Consumer) 不建议在单一进程内创建大量消费者
同一个消费组的订阅规则得一致吧,最好用不同的组。此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/