Value 消息的值（已强制转化为String类型），即消息的具体内容。消息创建时间 发送消息时，客户端自带的或是您指定的 ProducerRecord 中的消息创建时间。说明 如果配置了该字段，则按配置值显示。如果未配置该字段，则默认取消息发送时的...
您在使用 轻量消息队列（原 MNS）产品时，如果收到系统提示的错误信息，可查阅 错误码 匹配错误信息。对于其他问题，您可根据下列分类匹配问题场景和解决方案。产品介绍 什么是轻量消息队列（原 MNS）如何使用轻量消息队列（原 MNS）轻量...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
源 Topic：选择需要同步消息的源Topic。消息目标 目标地域：选择消息同步的目标Topic所属实例的地域。目标实例：选择消息同步的目标Topic所属实例。目标 Topic：选择消息同步的目标Topic。过滤规则 输入过滤规则，按照该规则过滤后的消息才...
对于上文描述的交互流程，建议使用 云消息队列 MQTT 版 提供的P2P消息，P2P消息不需要订阅，发送方直接指定对端接收即可，P2P消息的详细信息，请参见 P2P消息收发模式（MQTT）。收发消息参数设计 由于移动App可能存在应用切入后台被杀死...
消息堆积场景 如下图所示，表示指定主题的某一队列中各消息的状态：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和堆积情况，...
高频率消息发布：当客户端需要频繁地发布消息到相同的几个主题时，使用主题别名可以极大地减少冗余信息的发送。例如股市行情跟踪或 IoT 数据收集系统，这些系统可能每秒都会发送大量的消息。节能：对于以电池供电的设备，减少必须通过无线...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
在使用自建Kafka集群时，当您希望业务的成本更低、弹性更强、可靠性更高时，您可以将自建Kafka集群迁移上至 云消息队列 Kafka 版，云消息队列 Kafka 版 提供全托管、免运维的服务可以让您只需专注于业务开发，无需部署运维。注意事项 迁移...
MQTT消息的用户属性 mqtt5UserProperty 长度不能超过8K,例如：[{"key":"mQ","value":"test001"},{"key":"MQ","value":"test002"}]发送消息时指定的用户属性信息。MQTT消息的过期时间 mqtt5MsgExpireInterval 0-65535，单位s 发送消息时指定...
Kafka实例根据实例类型、Topic存储类型的不同，消息保留时长的配置方式以及生效的粒度都有所不同。Kafka实例从大版本上可以分为V2（预留实例）和V3（Serverless实例）两个版本：V3版本支持设置Kafka实例维度的消息保留时长（log.retention....
FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后...
消费者问题 消息的推送事件可以在 消息轨迹 内看到。若消息有推送事件，需要查看所在队列是否存在堆积，导致消息推送阻塞。若无堆积情况，或消息有推送事件，但是客户端一直未消费到，则需要针对消费者的运行情况进行排查。确认消费者运行...
2025-11-06 功能名称 功能描述 功能类型 相关文档 消息轨迹 轻量消息队列（原 MNS）提供消息轨迹查询功能，您可以通过消息轨迹查询消息的完整链路信息，包括消息的发送、订阅匹配、推送、消费等环节的时间、结果、生产者和消费者身份等信息...
本文介绍 云消息队列 Confluent 版 的产品功能动态及对应的文档。2024-08-20 功能名称 功能描述 功能类型 相关文档 日志管理 支持将 云消息队列 Confluent 版 实例的消息操作日志推送到日志服务。开通该服务后，您可以查询客户端的所有请求...
普通队列：普通消息的发送与消费，不保证消费的顺序。顺序队列：保证同一分组内的消息按照发送顺序进行消费。消息最大长度：发送到队列的消息体的最大长度。长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。设...
重要 队列粒度负载均衡策略保证同一个队列仅被一个消费者处理，该策略的实现依赖消费者和服务端的信息协商机制，云消息队列 RocketMQ 版 并不能保证协商结果完全强一致。因此，在消费者数量、队列数量发生变化时，可能会出现短暂的队列分配...
通过订阅ChatAppStatus下行状态报告，可以获知每条消息的发送情况，了解消息是否达到终端用户的状态与相关信息。ChatAppStatus ChatAppStatus ChatAppAudit（模板审核状态消息）模板审核状态消息是指通过CreateChatappTemplate接口创建模板...
步骤五：按位点查询消息 您可以根据发送的消息的分区ID和位点信息查询该消息。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 消息查询。在 消息查询...
步骤五：按位点查询消息 您可以根据发送的消息的分区ID和位点信息查询该消息。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 消息查询。在 消息查询...
定义 队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器，也是 云消息队列 RocketMQ 版 消息的最小存储单元。云消息队列 RocketMQ 版 的所有主题、轻量主题都是由一个或多个队列组成，以此实现队列数量的水平拆分和队列内部的流式...
该能力通过多种保障机制，在服务器版本发布、重启或维护期间，避免因客户端连接突然中断导致的生产或消费端报错、消息丢失等问题，确保业务连续性。保障机制 服务端节点禁写机制 在存储节点重启前，服务端会临时禁止该节点写入操作，等节点...
磁盘使用率介于[85%,90%)区间：无论消息是否超过 消息保留时长，根据服务端存储消息的时间先后顺序直接清除消息。磁盘使用率≥90%：为了保证稳定性，服务开启禁写保护，暂时无法写入新消息。非Serverless实例，Local存储Topic 磁盘使用率 ...
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
如果不设置死信消息的Routing Key，则死信消息的Routing Key默认为消息本身的Routing Key。死信消息 被重新发送到死信Exchange的消息。消息变成死信消息的可能原因如下：requeue 参数被设置为 false，消费者使用 basic.reject 或 basic....
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
最近更新时间 本分区中最近一条消息的存储时间。相关文档 当您的Topic上的分区数分配不均衡时，您可以查看 分区均衡引流 将集群中所有云存储类型的Topic的分区进行引流调整。如果您的部分分区消息数量相差过大，请参见 为什么发送给Topic的...
当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发轨迹，确保数据正常流转、快速定位异常。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择地域。在实例列表中找到目标实例...
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
说明 消息保留时长 指在磁盘容量充足的情况下，消息的最长保留时间。默认值为72小时，取值范围为24小时~480小时。磁盘容量不足（即磁盘水位达到85%）时，无论消息是否超过 消息保留时长，都将根据服务端存储消息的时间先后顺序提前删除旧的...
使用长轮询获取队列中的消息，popMessage请求会一直在服务端运行，直到有消息的时候才返回。既可以保证立即收到消息，又避免您发送大量无效请求，减少请求次数，降低费用。注意事项 如果popMessage请求返回无消息结果次数过多，可适当增加...
适用场景 通知公告：当某个重要公告或通知发布时，系统可以使用广播消费模式，将通知发送给所有订阅了该消息的用户。这样可以确保每个用户都能及时收到通知，并避免遗漏。实时数据同步：在分布式系统中，有时需要将某个数据进行实时同步，...
当消息的收发不符合预期时，您可以通过该接口查看消息的收发状态等轨迹信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessageOfClient 接口，都会计算为一次消息 TPS，从而影响您的计费。计费详情，请参见 计费...
在该模型中消息的生产者和消费者都是分布在终端设备，通过MQTT协议连接到 云消息队列 MQTT 版 产品。根据以上两种消息收发模型，可以将使用 云消息队列 MQTT 版 的开发人员分为终端和云端两大类。两类开发人员所需的二次开发内容请分别参见...
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 ...相关文档 更多关于Shovel插件的信息，请参见 Shovel Plugin。
本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，...
轻量消息队列（原 MNS）凭借其简单的队列模型、轻量化协议以及按量后付费的计费模式，成为众多阿里云产品首选的消息传输通道，此外，其无损发布能力和多可用区的高可用特性，确保了云产品之间以及云产品与用户应用之间的消息可靠传输。...
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
本文介绍如何在 云消息队列 MQTT 版 的控制台查询所有Topic的收发消息的数量和TPS。背景信息 此查询支持多维度筛选，以及自定义时间范围查询。您可以通过以下任一控制台路径进入查询页面：在控制台左侧导航栏，选择 资源报表。在控制台左侧...
如何获取部署实例时需要的VPC信息？升级Broker可能产生哪些影响？实例的地域无法变更 云消息队列 Kafka 版何时删除旧消息？如何快速测试云消息队列 Kafka 版服务端是否正常？是否支持延迟消息？能否通过公网访问云消息队列 Kafka 版实例？...