RocketMQ错误订阅关系

最新推荐文章于 2024-08-19 16:05:54 发布
最新推荐文章于 2024-08-19 16:05:54 发布
阅读量515 收藏
点赞数
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/It_sharp/article/details/106854904
版权
针对galaxy-realname和sto-trace-postal-service-push应用订阅同一GID和Topic但不同Tag时出现的问题，深入探讨可能由订阅关系不一致引起的消费停滞现象，及重启应用后的临时解决方案。

摘要生成于 C知道 ，由 DeepSeek-R1 满血版支持， 前往体验 >

https://help.aliyun.com/document_detail/43523.html?spm=a2c4g.11186623.6.731.37a738cbEQUo77
在这里插入图片描述

现在galaxy-realname 和 sto-trace-postal-service-push（推送管局实名信息） 订阅同一个GID，同一个Topic，不同的Tag，现在线上发现了一个问题，经常出现 sto-trace-postal-service-push 这个应用不消费实名信息了，日志和sunfire都没有消费的痕迹，重启应用后可以再次消费，可能是这个订阅关系不一致导致的

可以用一个consume

It_sharp
关注
RocketMq订阅关系不一致理解
ZhiguoXue_IT的博客
01-12 583
在RocketMQ的使用过程中，会遇到当前Group下的消息订阅关系不一致的问题，当出现订阅关系不一致时，可能会出现消息丢失、堆积等问题，之前遇到过订阅关系不一致，导致消息丢失，对出现问题的原因进行解析。
RocketMQ订阅关系不一致浅析
datastructure18的博客
11-30 2889
本文先介绍背景，分析官方文档中的一些场景，包括正确和错误的订阅关系，然后对出现订阅关系不一致进行原来解析，最后对MQ消息出现问题的场景做出应对解决方案。
基于RocketMQ的分布式事务解决方案
weixin_44407691的博客
10-14 280
转载地址：https://www.jianshu.com/p/286cac4625b6 前言 在系统变的复杂后，分布式、微服务等架构技术，就要考虑到应用在系统中了。尤其数据量大了后，就需要对数据库进行拆分。 如：注册的用户数据，量大了后，就需要考虑分库分表 一旦数据库进行了分拆，那就出现很多头疼的问题，其中之一就是事务问题。那我们就来看看问题是怎么出现的？ 场景 先来上个图 进行数据拆分后，就类似上面的架构 上图中我们就拿用户的数据进行举例，**用户量一旦几千万时，就需要进行分库分表**；上图就分了3个
聊聊rocketmq的订阅关系
go4it
05-08 804
本文主要研究一下rocketmq的订阅关系。
RocketMQ (十二) 订阅关系-Subscription
dmjxsy的博客
03-10 2135
RocketMQ(订阅关系)
RocketMQ-订阅一致及解决方案
码仔谢的博客
07-05 1965
订阅关系一致的终极解决方案
RocketMQ 基础教程-原理篇-订阅关系的一致性
smart_an的专栏
06-25 966
作者简介：大家好，我是哥，前中兴通讯、美团架构师，现某互联网公司联系qq：184480602，加我进群，大家一起学习，一起进步，一起对抗互联网寒冬学习必须往深处挖，挖的越深，基础越扎实！订阅关系的一致性指的是，同一个消费者组（Group ID相同）下所有Consumer实例所订阅的Topic与Tag及对消息的处理逻辑必须完全一致。否则，消息消费的逻辑就会混乱，甚至导致消息丢失。
阿里云RocketMQ订阅失败
for_the_time_begin
06-29 2078
阿里云mq订阅有几个特点： 1. 同一个topic可以被多个Group订阅，生产者每次生产一个消息，都会广播给订阅了当前topic的所有Group，每个Group均可以独立消费。在topic基础信息里可以看到具体信息 2. 一个Group只能订阅一个topic，否则就会出现订阅不一致，在Group基础信息里可以看到具体信息 3. 一个Group可以对应多个Consumer 实例，Consumer 实例可以理解为不同的机器，在Group基础信息里可...
RocketMQ订阅关系一致性分析
Soda_lw的博客
11-04 4129
RocketMQ的消费者，在订阅topic的时候需要遵循“订阅关系一致性”原则，即：一个消费者分组（group）下的所有消费者实例的处理逻辑必须一致，一旦订阅关系不一致就会导致消费混乱，甚至消息丢失。对大多数分布式应用来说，一个group下通常会挂有多个consumer实例。由于RocketMq的消费者订阅关系由Topic+Tag组成，因此保持订阅一致就意味着，所有consumer实例需要保证： ...
深入浅出消息队列----【订阅关系一致性】
最新发布
是微风，是晚霞，是无可替代
08-19 1090
所谓的订阅关系，讲白了就是记录某个 consumer 订阅了某主题（含过滤条件如 tag），然后 consumer 去 Broker 拉取消息的时候，根据订阅关系就能拉取到正确的消息。实际生产上，都是由多个 consumer 组成消费组来消费消息的，这样一来对不熟悉订阅关系或者说不了解原理的人，在使用上就很容易出现错误。RocketMQ 中，订阅关系是按照消费组和主题 + tag 粒度设计的，也就是说一个订阅关系=某消费组+某主题+某tag。
RocketMQ(13) -- RocketMQ工作原理-- 订阅关系的一致性
姜皓的博客
05-06 676
RocketMQ工作原理-- 订阅关系的一致性
7.RocketMQ-订阅关系一致性分析
qq_24223159的博客
04-07 1266
文章目录不一致原因解析问题一：订阅消息相互覆盖问题二：消息负载均衡后导致消息延迟消费，甚至报错The consumer’s subscription not exist RocketMQ的消费者，在订阅topic的时候需要遵循“订阅关系一致性”原则，即：一个消费者分组（group）下的所有消费者实例的处理逻辑必须一致，一旦订阅关系不一致就会导致消费混乱，甚至消息丢失。对大多数分布式应用来说，一个group下通常会挂有多个consumer实例。由于RocketMq的消费者订阅关系由Topic+Tag组成，因此
RocketMQ之订阅关系一致性
李大能
07-02 489
订阅关系一致性
RocketMQ为什么要保证订阅关系的一致性？
后端进阶
07-29 2965
前段时间有个朋友向我提了一个问题，他说在搭建 RocketMQ 集群过程中遇到了关于消费订阅的问题，具体问题如下：然后他发了报错的日志给我看：the consumer's...
RocketMQ部分消息消费不到的问题--订阅关系一致
骏马逸动，心随你动的博客
07-13 3807
问题： 在阿里云服务提供的消息队列服务（RocketMQ）中，给出了一份关于订阅关系一致的最佳实践，在文档中指出同一个 GroupID 中的所有消费者实例最好订阅同样的 Topic+Tag。这让我有一些疑问，为什么一个 GroupID 只能产生一种订阅，这样岂不是同一个应用需要订阅不同的 Topic 那么每一次都需要去申请一个 GroupID，这使得 GroupID 和 Topic 产生了一定的耦合关系，看起来是不太合理的，那么为什么 RocketMQ 要这么做呢？ 参考：https://blog.csd
消息队列(RocketMQ)：订阅消息一致性问题解决方案
HelloQ的博客
05-28 2694
订阅一致性的可能情况以及处理方案 订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例的处理逻辑必须完全一致。一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失 保持订阅关系一致意味着同一个消费者 Group ID 下所有的实例需在以下两方面均保持一致 订阅的 Topic 必须一致 订阅的 Topic 中的 Tag 必须一致 错误情况： 同一个 Group ID 下的两个实例订阅的 Topic 不一致 同一个 Group ID 下订阅 Topic 的 Tag 不一
RocketMq 消费者 异常 订阅了，但是被过滤掉了；同一group，同一topic，同一tags
泯灭于众生，高歌于孤夜！
03-26 934
异常现象： mq消费者消费消息异常，显示订阅了，但是被过滤掉了；如下图： 排查所有的group、topic、tags与生产者一致，无误。非常奇怪。后百度，有人说 具体参考地址：https://blog.csdn.net/yangchenhui666/article/details/104587147 我目前的环境中在同一个group、topic下有两个业务场景同时使用，只不过tags不同而已。 个人解决办法：变更不同的group进行处理即可。 ...
RocketMQ 常见异常处理
愿世界和平
10-17 8290
MQClientException: No route info of this topic, TopicTest1 异常说明 在客户端的 Producer 运行起来准备发送消息时抛异常如下 “ No route info of this topic ” 异常产生的原因可能是，自己当时的原因恰好是第三条： Broker 禁止自动创建 Topic，且用户没有通过手...
Spring Boot 整合 RocketMq
秋天的博客
11-25 485
Spring Boot 整合 RocketMq Spring Boot 整合 RocketMq 1.pom.xml添加RocketMq依赖 <dependency> <groupId>com.alibaba.rocketmq</groupId> <artifactId>rocketmq-client</...
rocketmq订阅关系没有是什么原因
05-31
2. 订阅者配置错误：如果订阅者的配置不正确，比如订阅的主题名称或标签不正确，订阅关系也无法建立。 3. 消息没有被正确发送：如果生产者没有正确发送消息到RocketMQ服务器，订阅者当然就无法消费到消息。 4. ...
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值