RocketMQ client.exception.MQBrokerException: CODE: 24 DESC: the consumer's subscription not exist 问下是不是一个topic 只能对应一个消费组?我用的是5.3版本。如果不是,那这个报错是什么原因呢?目前程序设置的是 一个消费组对应多个topic
“CODE: 24 DESC: the consumer's subscription not exist”是一个 MQBrokerException 错误,表示消费者订阅的主题不存在。
在一个消费组内,您可以将多个 Topic 分配给不同的消费者,但是需要注意的是,一个 Topic 在同一时刻只能被一个消费组所订阅。因此,如果您试图让一个消费组订阅一个已经被另一个消费组订阅的主题,就会触发此错误。
为了防止这个问题发生,请确保您在同一时刻没有两个或更多个消费组订阅同一个主题。另外,也可以尝试刷新您的消费组或者重新订阅主题来解决问题。
RocketMQ的一个Topic可以对应多个Consumer Group(消费组),但每个Consumer Group只能订阅一个Topic。所以,如果你在一个Consumer Group中同时订阅了多个Topic,就会出现你看到的错误信息 "the consumer's subscription not exist"。
解决这个问题的方法是,为每个Topic创建一个独立的Consumer Group。例如,如果你有三个Topic:A、B、C,你可以创建三个Consumer Group:GroupA、GroupB、GroupC,分别订阅这三个Topic。
另外,这个错误信息也可能是因为你的Broker(消息代理)没有正确配置导致的。你可以检查一下你的Broker配置,确保所有的Topic和Consumer Group都已经正确配置。
不是。看看topic和消费组是否对应上,而且rmq不建议一个消费组消费多个topic,这点还是和kafka有区别的。如果用的是remot的方式,那还是区分开,一个topic用一个group。此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/