开发者社区 > 云原生 > 云消息队列 > 正文

RocketMQ事务消息这个tag 过滤逻辑。 是需要一个topic 申请多个消费者组吗?

RocketMQ事务消息这个tag 过滤逻辑。 是需要一个topic 申请多个消费者组吗?

比如 有两套环境一个topic, a 环境 生成 tag=a的消息, b环境 生成tag=b的消息
这两套环境都在消费同一个消费者组会有问题吗。 目前发现好像是消费不全。

展开
收起
嘟嘟嘟嘟嘟嘟 2024-07-23 23:34:41 100 0
2 条回答
写回答
取消 提交回答
  • RocketMQ的事务消息与Tag过滤逻辑是独立的。每个消费者组可以订阅多个Tag,但同一消费分组内不建议创建多个消费者。如果a环境和b环境都在同一个消费者组内消费同一个Topic,并且分别生成tag=a和tag=b的消息,这可能导致消息消费不全。
    正确做法是创建两个不同的消费者组,每个组消费特定的Tag。这样,a环境的消费者组仅消费tag=a的消息,b环境的消费者组消费tag=b的消息,保证消息正确路由和完整消费。请检查您的消费者配置,确保每个环境使用独立的消费者组。可参考云消息队列 RocketMQ 版 消费者(Consumer) 不建议在单一进程内创建大量消费者

    2024-07-24 10:27:50
    赞同 展开评论 打赏
  • 同一个消费组的订阅规则得一致吧,最好用不同的组。此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”

    2024-07-23 23:44:13
    赞同 5 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载