收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
版本说明
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
MQTT客户端上下线事件数据流出
您可通过配置 云消息队列 MQTT 版 的客户端上下线通知规则，将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云...
发送消息时返回“MQClientException:No route info of...
解决方案 登录 云消息队列 RocketMQ 版 控制台。在 实例详情 页面查看实例的接入点，检查代码中设置的接入点是否和控制台提供的一致。在 Topic 管理 页面查看代码中设置的Topic是否已创建且拼写正确。在 实例详情 页面的 基础信息 区域查看...
什么是消息服务MNS
队列模型消息流 队列模型特性 多种队列模式 支持普通队列、延迟队列。您可以个性化地配置队列属性以满足不同应用场景。海量并发访问 支持多个生产者和消费者并发访问同一队列，并能确保某条消息在取出之后的特定时间内，无法被其他消费者...
Topic删除后不能减少分区？
问题现象 您在删除某个分区数为XX的Topic后，再次创建该Topic并将分区数配置为小于XX，系统提示 创建topic成功，分区数不能小于曾经配置过的分区数，已重置为XX。可能原因 老版本删除Topic时，不会彻底清除路由，导致再次创建Topic时无法...
自定义鉴权模式
过期设置：云消息队列 MQTT 版 对于身份认证、资源授权以及连接黑名单等数据暂不提供过期设置功能，您可以及时删除相关接口进行管理。容量限制：无论是身份认证，还是资源权限都占用了实例的元数据存储，所以您需要自行管理鉴权数据，及时...
死信消息
本文介绍死信消息的应用场景、死信策略、使用限制、配置方法和使用建议。应用场景 典型死信消息处理场景 消息重试失败后，您可以选择将死信消息存储到指定的死信Topic中，通过另外创建一个ConsumerGroup消费这些死信消息来处理异常链路或...
开启幂等功能，发送消息报“Cluster authorization ...
问题描述 开启幂等功能后，发送消息时客户端报 Cluster authorization failed 错误。问题原因 您使用了云存储Topic，云存储Topic不支持幂等功能。如果使用Local Topic，并开启了ACL功能，默认情况下，根据Kafka开源协议，Broker会判断发送...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
OnsMessageDetail-查询消息详细信息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。调试 您可以在OpenAPI Explorer中直接...
AMQP协议返回码
本文说明 云消息队列 RabbitMQ 版 客户端调用AMQP 0-9-1协议时的返回码，您可以根据返回信息与解决方案自助排查错误。返回码列表 返回码（reply-code）返回信息（reply-text）描述 解决方案 200 no route has mandatory 调用 basicPublish ...
服务支持
云消息系列 RocketMQ 版常见问题 产品功能常见问题 客户端连接常见问题 售卖、计费和实例升降配常见问题 控制台常见问题 消息发送常见问题 消息消费常见问题 相关协议 阿里云产品服务协议（通用）云消息队列 RocketMQ 版服务等级协议
服务支持
本文汇总了 云消息队列 Kafka 版 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议
如何处理不活跃的Topic
概述 本文主要介绍如何处理历史Topic或不活跃的Topic，以减少资源占用量。详细信息 请先判断Topic的活跃状况，对于不活跃的Topic，您可以考虑进行删除，具体步骤如下。...相关文档 Topic相关问题 云消息队列 Kafka 版 的常见问题
服务关联角色
常见问题 为什么我的RAM用户无法自动创建消息队列RocketMQ版服务关联角色AliyunServiceRoleForOns？如果阿里云账号已经创建了服务关联角色，RAM用户就会继承该阿里云账号的服务关联角色。如果没有继承，请登录 RAM控制台 为其添加以下权限...
计费概述
计费常见问题 计费常见问题 出账与欠费说明 标准版实例计费 标准版实例的计费方式为按量付费（后付费），适合消息量少或消息波峰波谷差异明显的业务场景，根据您实际使用的消息量和资源进行收费，可以有效避免资源浪费。消息收发费用 消息...
服务关联角色
常见问题 为什么我的RAM用户无法自动创建 云消息队列 RocketMQ 版 服务关联角色AliyunServiceRoleForOns？如果阿里云账号已经创建了服务关联角色，RAM用户就会继承该阿里云账号的服务关联角色。如果没有继承，请登录 RAM控制台 为其添加...
消息过滤
消息过滤常见问题 多个消费者订阅同一个Topic下的不同Tag，出现消息丢失情况。可能原因：若多个消费者是通过同一个消费者分组（Group ID）订阅的指定Topic，则所有消费者的过滤条件即订阅的Tag要一致，否则会出现订阅关系不一致，导致部分...
仪表盘
仪表盘常见问题 如何将仪表盘的指标数据接入自建Grafana?云消息队列 RocketMQ 版 的所有指标数据已保存到您的阿里云可观测监控 Prometheus 版中，您可以通过可观测监控 Prometheus 版提供的API将 云消息队列 RocketMQ 版 的仪表盘的指标...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
队列（MessageQueue）
常见队列增加场景 需要增加队列实现物理节点负载均衡 云消息队列 RocketMQ 版 每个主题的多个队列可以分布在不同的服务节点上，在集群水平扩容增加节点后，为了保证集群流量的负载均衡，建议在新的服务节点上新增队列，或将旧的队列迁移到...
重置消费位点
消费位点重置常见问题 我使用两种方式重置消费位点均失败，该怎么处理？请确认是否为集群消费。广播模式不支持重置消费位点。确认当前消费者是否在线。消费者必须在线才能重置消费位点。确认SDK版本，SDK版本过低也会导致此问题。建议升级...
服务关联角色
本文介绍 云消息队列 Kafka 版 服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
查询消息轨迹
消息状态说明 状态类型 状态参数 发送状态 发送成功 发送失败 消息定时中 事务未提交 事务回滚 消费状态 全部成功 部分成功 全部失败 尚未消费 消费结果未返回 消费成功 消费失败 消息轨迹常见问题 为什么查询不到消息轨迹？检查客户端的...
4.x和5.x版本差异及兼容性说明
运维门槛更低 针对线上容量水位评估、业务峰谷弹性、日常灰度环境等常见困难问题提供自适应弹性、轻量测试环境版等解决方案，整体运维门槛和风险更低。成本更弹性 通过云底座技术优化，消息收发计算能力支持预留+突发流量弹性组合，业务方...
客户端连接常见问题
本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述 资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因 接入点格式不正确，正确...
4.x和5.x版本差异及兼容性说明
运维门槛更低 针对线上容量水位评估、业务峰谷弹性、日常灰度环境等常见困难问题提供自适应弹性、轻量测试环境版等解决方案，整体运维门槛和风险更低。成本更弹性 通过云底座技术优化，消息收发计算能力支持预留+突发流量弹性组合，业务方...
基于Flink的资讯场景实时数仓
解决的问题 通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据处理和数据流。通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据分析。通过 云消息队列 Kafka 版 和实时计算Flink实现事件触发。部署架构图 选用的产品 云消息队列 ...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
资源包说明
云消息队列 RocketMQ 版 的标准版实例按照按量付费方式对API请求资源和Topic资源进行计费，针对这两个计费项，云消息队列 RocketMQ 版 分别推出API请求次数和Topic次数资源包，帮助您以更优惠的价格享受等量资源。使用的资源在资源包规格内...
消息存储和清理机制
消息在队列中的存储情况如下：消息存储管理粒度说明 云消息队列 RocketMQ 版 按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版 基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
标签管理
本文介绍如何为 云消息队列 Kafka 版 的实例、Topic、Group 等资源绑定标签，从而帮助您根据标签给资源归类，高效管理资源。背景信息 标签由标签键和标签值组成，可以标记 云消息队列 Kafka 版 的资源。如果您的账号下有多种 云消息队列 ...
死信队列
排查可疑因素并解决问题后，您可以在 云消息队列 RocketMQ 版 控制台重新发送该消息，让消费者重新消费一次。重要 对于顺序消息消费产生的死信消息，不支持从死信队列重新发送，您需要将消息从死信队列导出后自行处理。死信消息被重新发送...
计费常见问题
本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 ...
接口调用常见问题
本文介绍调用 云消息队列 MQTT 版 接口时的常见问题。调用接口时有不定时超时报错。云消息队列 MQTT 版 针对API的调用频率有限制，即QPS限制。超过限制则会被限流。具体限制规则和限制值，请参见 QPS限制。使用SDK方式调用API返回...
- 产品推荐
- 这些文档可能帮助您