队列故障原因-队列故障原因文档介绍内容-阿里云

为什么消费客户端频繁出现Rebalance？

可能原因可能导致故障的原因包括：v0.10.2之前版本的客户端：Consumer没有独立线程维持心跳，而是把心跳维持与poll接口耦合在一起。其结果就是，如果用户消费出现卡顿，就会导致Consumer心跳超时，引发Rebalance。v0.10.2及之后版本的客户...

消息发送重试和流控机制

消息发送重试机制重试基本概念云消息队列 RocketMQ 版客户端连接服务端发起消息发送请求时，可能会因为网络故障、服务异常等原因导致调用失败。为保证消息的可靠性，云消息队列 RocketMQ 版在客户端SDK中内置请求重试逻辑，尝试通过重...

生产者负载均衡

异常处理当发送某条消息发送失败时，云消息队列 RocketMQ 版会根据失败原因决定在接下来一段时间内，选择队列目标时跳过本地失败队列所在的节点，快速实现自适应的故障隔离。策略特点 RoundRobin模式的生产者负载均衡策略仅适用于无顺序...

消息存储和清理机制

消息在队列中的存储情况如下：消息存储管理粒度说明云消息队列 RocketMQ 版按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...

通过可观测性能力进行故障处理最佳实践

本文为您介绍如何将云消息队列 RocketMQ 版可观测性功能应用于云消息队列 RocketMQ 版的故障管理场景中，为您的日常运维和故障处理提供实践方案。设计思路核心问题运维场景下，故障处理的核心问题如下：服务出现异常如何预警并上报 ...

如何处理消息堆积

可能原因云消息队列 RocketMQ 版的消息发送至Broker节点后，配置了Group ID的客户端根据当前的消费位点，从Broker节点拉取部分消息到本地进行消费。一般情况下，客户端从Broker节点拉取消息的过程不会导致消息堆积，主要是客户端本地消费...

查看消费者状态

如果消息消费出现异常，您可以在云消息队列 RocketMQ 版控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景消费者状态信息包括在线...

配置消息监控告警实现风险预警

云消息队列 RocketMQ 版支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息云消息队列 RocketMQ 版提供全托管的消息服务，对于每个规格...

消费者负载均衡

消费者从云消息队列 RocketMQ 版获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍云消息队列 RocketMQ 版消费者的负载均衡...

配置消息监控告警实现风险预警

云消息队列 RocketMQ 版支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息云消息队列 RocketMQ 版提供全托管的消息服务，对于每个规格...

消息过滤

消费者订阅了某个主题后，云消息队列 RocketMQ 版会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在云消息队列 RocketMQ 版服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...

消费重试

消费者出现异常，云消息队列 RocketMQ 版会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景云消息队列 RocketMQ 版的消费重试主要解决的是业务处理逻辑失败导致的...

定时/延时消息

云消息队列 RocketMQ 版定时消息的状态支持持久化存储，系统由于故障重启后，仍支持按照原来设置的定时时间触发消息投递。若存储系统异常重启，可能会导致定时消息投递出现一定延迟。使用示例和普通消息相比，定时消费发送时，必须设置...

消息堆积和延迟问题

通过了解云消息队列 RocketMQ 版客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或在运维过程中及时调整业务逻辑，避免因消息堆积和延迟影响业务运行。背景信息消息处理流程中，如果客户端的消费...

报警项状态显示数据不足怎么办？

可能原因老版云消息队列 Kafka 版实例不支持报警数据上报。解决方案登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。在实例列表页面，单击目标实例名称。在实例详情页面，单击配置信息页签，然后单击...

开源对比

项目云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式云消息队列 Kafka 版控制台云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建云消息队列 Kafka 版默认通过阿里云控制...

配额与限制

云消息队列 RocketMQ 版对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用云消息队列 RocketMQ 版时不要超过对应的限制值，避免应用出现异常。参数限制以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...

消息轨迹

在分布式应用中，云消息队列 RocketMQ 版作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版定义的轨迹参数...

无法ping通云消息队列 Kafka 版的接入点

问题原因为了保证安全，云消息队列 Kafka 版集群默认禁ping。连接VPC接入点时，客户端与Kafka不在同一VPC下。解决方案您可以通过 telnet 命令测试网络连通性。但需要注意以下几点要求：执行 telnet 命令的客户端在白名单范围内。如果 ...

QueueHasDiffField

本文为您介绍云消息队列 RabbitMQ 版客户端报QueueHasDiffField类型错误的原因和处理方法。问题现象使用云消息队列 RabbitMQ 版客户端连接云消息队列 RabbitMQ 版服务端时，报QueueHasDiffField类型错误。例如QueueHasDiffField...

ExchangeHasDiffFields

介绍云消息队列 RabbitMQ 版客户端报ExchangeHasDiffFields类型错误的原因和处理方法。问题现象使用云消息队列 RabbitMQ 版客户端连接云消息队列 RabbitMQ 版服务端时，报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields...

查看任务执行记录

在某个实例下发起重启类任务（包括配置变更、版本升级、开启ACL、实例升配）后，您可以在云消息队列 Kafka 版控制台查看重启类任务的执行记录，帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件创建并部署云消息队列 Kafka 版 ...

可观测性体系概述

日志云消息队列 RocketMQ 版为不同的异常情况定义唯一的错误码及错误信息，并划分不同的错误级别，您可以根据客户端返回的错误码信息快速获取异常原因。和4.x版本相比，云消息队列 RocketMQ 版服务端5.x版本统一了ErrorCode和...

订阅者最佳实践

本文主要介绍云消息队列 Kafka 版订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程云消息队列 Kafka 版订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡每个 ...

死信队列

对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...

OnsDLQMessageResendById-重发指定的死信消息

由于死信消息是经过重试逻辑依然消费失败的消息，通常意味着消费逻辑可能存在问题，故请先查明多次消费失败的原因，再调用本接口重新发送。当前消息队列 RocketMQ 版不管理死信重发的状态，重发后消费成功的消息不会从死信队列中移除。需...

消息（Message）

消息持久化云消息队列 RocketMQ 版会默认对消息进行持久化，即将接收到的消息存储到云消息队列 RocketMQ 版服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系在整个云消息队列 RocketMQ 版的领域模型中...

API概览

本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...

OnsMessageTrace-查看消息消费结果

本接口一般在消费异常，需要判断消息消费状态，初步排查原因时使用。本接口的实现基于云消息队列 RocketMQ 版的内部位点机制，在大部分场景下判断结果可信，但如果应用方进行过重置位点已经清除消息等操作，则判断结果可能有误。调试您...

查看分区状态

当Kafka集群出现消息堆积、磁盘水位过高等异常情况时，可查看分区状态了解服务端的消息量及各个分区的消费进度，定位异常原因。前提条件已创建Topic 操作步骤登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。...

发送消息时返回“MQClientException:No route info of...

问题现象使用TCP协议SDK发送消息时，云消息队列 RocketMQ 版服务端返回如下错误：Caused by:com.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic 可能原因代码中设置...

开源对比

云消息队列 RabbitMQ 版是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...

查看Rebalance详情

当消费客户端出现Rebalance时，您可以查看Rebalance的详情，包括Rebalance的时间、耗时、次数、原因以及是否有新成员加入。背景信息 Rebalance是云消息队列 Kafka 版对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户...

事务消息

消息回查：由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，云消息队列 RocketMQ 版服务端通过扫描发现某条消息长期处于“半事务消息”时，需要主动向消息生产者询问该消息的最终状态（Commit或是Rollback），该...

为什么Group管理页面的Group变多了？

可能原因若Group的自动创建栏为否，说明此Group创建于云消息队列 Kafka 版控制台的 Group 管理页面。若Group的自动创建栏为是，可能是以下原因：若您开启了自由使用Group功能，云消息队列 Kafka 版会自动在Kafka集群上创建对应...

新功能发布记录

优化按量计费转包年包月 2022-11-17 功能名称功能描述功能类型相关文档控制台支持查看实例的Rebalance详情当消费客户端出现Rebalance时，云消息队列 Kafka 版支持在控制台上查看Rebalance详情，包括时间、耗时、次数、原因及是否有...

客户端连接常见问题

本文介绍云消息队列 MQTT 版客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因接入点格式不正确，正确...

消费进度管理

云消息队列 RocketMQ 版通过消费位点管理消费进度，本文为您介绍云消息队列 RocketMQ 版的消费进度管理机制。背景信息云消息队列 RocketMQ 版的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...

使用云消息队列 Kafka 版时出现“Not authorized to ...

问题原因没有创建Consumer Group时会遇到此报错信息。解决方案您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台创建Consumer Group。具体步骤请参见创建Consumer Group。调用管控API创建Consumer Group。

开源RabbitMQ迁移上云

云消息队列 RabbitMQ 版采用了独创的架构设计，有效避免了因消息积压导致的内存泄漏和服务器故障等稳定性问题，并成功解决了分布式系统中的脑裂难题。此外，它还提供了高度的可伸缩性和灵活的按量计费模式，进一步增强了服务的弹性、降低...

队列故障原因

新品推荐