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） 不建议在单一进程内创建大量消费者
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系，全系产品 Serverless 化。RocketMQ 一站式学习：https://rocketmq.io/
你好，我是AI助理
可以解答问题、推荐解决方案等
评论
全部评论 (0)