GetQueueAttributes
PollingWaitSeconds Integer 0 当Queue消息量为空时，针对该Queue的ReceiveMessage请求最长的等待时间，单位为秒。ActiveMessages Integer 20 在该Queue中处于Active状态的消息总数，为近似值。InactiveMessages Int 0 在该Queue中处于...
SetQueueAttributes
PollingWaitSeconds Integer 否 0 当Queue消息量为空时，针对该Queue的ReceiveMessage请求最长的等待时间。取值范围：0~30，单位为秒。默认值：0。LoggingEnabled Boolean 否 True 是否开启日志管理功能。取值说明如下：True：启用。False...
收发事务消息
TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到...
收发普通消息
TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到...
收发定时消息
Message msg(/Message Topic factoryInfo.getPublishTopics(),/Message Tag，可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤"TagA",/Message Body，不能为空，消息队列RocketMQ版不...
示例代码
TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到...
调用TCP协议的SDK收发普通消息
TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到...
管理Kafka JSON Catalog
infer-schema.parse-key-error.field-name String 解析JSON格式消息键（Key）时，如果消息键不为空，且解析失败，会添加 key.fields-prefix 前缀拼接此配置项的值为列名，类型为VARBINARY的字段到表Schema，表示消息键部分的数据。...
推送到移动设备
消息服务MNS 支持把发布到主题的消息推送到移动端。本文介绍如何将消息推送到移动端。前提条件 开通移动推送 创建应用 集成SDK 步骤一：创建主题...置空为立即发送。保存离线消息：选择是否保存离线消息。更多参数说明，请参见 推送高级接口。
MQTT与RocketMQ的消息结构映射
MQTT子级Topic mqttSecondTopic 具体的子级Topic字符串 云消息队列 RocketMQ 版 发给 云消息队列 MQTT 版 客户端消息时如果需要子级Topic来做过滤，则设置，如不设置，默认为空；云消息队列 MQTT 版 发给 云消息队列 RocketMQ 版 的消息...
AMQP协议返回码
MessageBodyEmpty 消息体内容为空。请输入消息内容。503 ExchangeTypeNotSupport[x-delayed-message]使用代码方式创建x-delayed-message类型的Exchange时，参数设置错误。重点检查Exchange类型和x-delay-type参数值设置是否正确。正确示例...
API错误码
InvalidParameter.MessageTypeNotEmpty 当发送非模板消息时消息类型不能为空。InvalidParameter.ContentNotEmpty 当发送非模板消息时消息内容不能为空。InvalidParameter.ContentError 消息内容格式不正确，具体格式请参见接口文档。...
自定义Pro版集群的控制面组件参数
featureGates 可选参数包括 ServerSideApply、TTLAfterFinished、EphemeralContainers、RemoveSelfLink、HPAScaleToZero，默认为空。说明 支持在1.18及以上集群中使用 HPAScaleToZero，不支持在1.24及以上集群中修改 RemoveSelfLink。...
自定义Pro版集群的控制面组件参数
featureGates 可选参数包括 ServerSideApply、TTLAfterFinished、EphemeralContainers、RemoveSelfLink、HPAScaleToZero，默认为空。说明 支持在1.18及以上集群中使用 HPAScaleToZero，不支持在1.24及以上集群中修改 RemoveSelfLink。...
查询群组消息列表
MsgType Long 否 1 需要查询的消息类型，若为空则默认为全部类型。BeginTime Long 否 1697783235 查询起始时间，用UNIX时间戳表示，单位：秒。若为空则默认为最早时间。EndTime Long 否 1698301635 查询结束时间，用UNIX时间戳表示，单位：...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？...订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？...订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
如何查看哪些IP在消费消息？
在控制台根据 Group 查看消费状态。在控制台根据 Group 查看消费状态，在 消费状态 页签，单击Topic右侧 操作 列的 消费详情，可以看到消费客户端对应的IP。如果数据为空，说明客户端不在线或者处于 Rebalance 中。
消费者分类
说明 由于服务端存储为分布式，可能会出现服务端实际有消息，但是返回为空的现象。一般可通过重新发起ReceiveMessage调用或提高ReceiveMessage的并发度解决。批量拉取消息数：SimpleConsumer可以一次性批量获取多条消息实现批量消费，该...
快速入门概述
主题模型 主题模型消息流 主题模型特性 主题模型基本概念 队列模型快速入门 如 队列模型快速入门流程 所示，本教程以直接在控制台发送和接收消息为例。图 1.队列模型快速入门流程 队列模型在控制台发送和接收消息的流程如下：创建队列 发送...
云消息队列 Kafka 版何时删除旧消息？
清理消息为动态控制管理，无需且不支持手动删除。磁盘使用率可在 实例详情 页面的 可观测>云监控 页面中查看，具体操作，请参见 云监控。Topic详情 页面中的 当前服务器上消息总量 是指Topic上所有发送还未超过消息保留时间的消息量。此...
CreateConsumerGroup-创建消费组
不允许为空。最多支持 128 个字符，不能以 aliyun 和 acs:开头，不能包含 http:// 或者 https:// 。FinanceDept Value string 否 资源的标签值。N 为 1~20。可以为空。最多支持 128 个字符，不能以 aliyun 和 acs:开头，不能包含 http:// ...
快速入门概述
本文以收发普通消息为例进行说明，因此，您按照本文提供的步骤创建的普通消息的Topic，不能用于收发其他类型的消息。换言之，不同消息类型的Topic不能混用。使用流程 根据您选择的协议，使用流程如下。协议使用须知 由于 云消息队列 ...
TagResources-为资源绑定标签
不允许为空。最多支持 128 个字符，不能以 aliyun 和 acs:开头，不能包含 http:// 或者 https:// 。FinanceDept Value string 否 资源的标签值。N 为 1~20。可以为空。最多支持 128 个字符，不能以 aliyun 和 acs:开头，不能包含 http://...
消息负载均衡策略
Msg2-1表示该消息为Queue1中的第2条消息，且消息的ShardingKey为1。该图标背景色表示消息属于Queue 2；Msg3-2表示该消息为Queue2中的第3条消息，且消息的ShardingKey为2。图中Msg1-1、Msg2-1和Msg3-1这三条消息的Sharding Key都是1，因此被...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
生产者负载均衡
策略原理：轮询方式 RoundRobin模式下，生产者发送消息时，以消息为粒度，按照轮询方式将消息依次发送到指定主题中的所有可写目标队列中，保证消息尽可能均衡地分布到所有队列。如上图所示，M1、M2表示生产者发送的第一条消息、第二条消息...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
事务消息
云消息队列 RocketMQ 版 服务端将消息持久化成功之后，向生产者返回Ack确认消息已经发送成功，此时消息为半事务消息。生产者开始执行本地事务逻辑。生产者根据本地事务执行结果向服务端提交二次确认结果（Commit或是Rollback），服务端收到...
创建MNS Sink Connector
test 开启 Base64 编码 选择是否开启Base64编码，如不开启，会导致接收到的消息为乱码。是 消息体（body）选择事件内容转换类型。更多信息，请参考 事件内容转换。完整事件 任务属性 设置此任务的重试策略及死信队列。更多信息，请参见 重...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
顺序消息
如何实现顺序消息 全局顺序消息和分区顺序消息原理一样，下文以分区顺序消息为例介绍在 云消息队列 RocketMQ 版 中如何保证消息收发的顺序。在 云消息队列 RocketMQ 版 中，消息的顺序需要由以下三个阶段保证：消息发送 如上图所示，A1、B1...
收发事务消息
} } 事务回查机制说明 发送事务消息为什么必须要实现回查Check机制？当半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow，或者应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半事务消息的状态是未知的...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，以如下消息为例：订单消息 支付消息 物流消息 这些消息会发送到名称为 Trade_Topic的Topic中，被各个不同的系统所订阅，以如下系统为例：支付系统：只需...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
TCP协议客户端大版本发布
以消息为粒度进行负载，负载策略更加均衡。避免了队列级负载策略可能引起的消费者空闲或消息堆积问题。仪表盘 只有消息收发量和堆积量等少数指标项。新增了消息堆积场景的指标数据，帮助您更高效定位问题。增加了消息收发各环节的耗时、...
查询消息轨迹
MQ Server 消息类型 普通消息 定时消息 顺序消息 事务消息 说明 发送的消息为定时消息或延时消息时，消息类型 都显示为 定时消息。到达Server 消息到达 云消息队列 RocketMQ 版 服务端的时间。预设DeliverAt 定时消息的预计投递时间。实际...
收发事务消息
} } 事务回查机制说明 发送事务消息为什么必须要实现回查Check机制？当步骤1中半事务消息发送完成，但本地事务返回状态为 LocalTransactionState.UNKNOW，或者应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条Half状态的消息...
Exchange管理
发送消息 为Exchange添加绑定或被绑定关系后，可直接在控制台发送消息，将消息从Exchange发送到绑定的Queue中，或从被绑定的Exchange发送到源Exchange中。在 Exchange 列表 页面，选择指定Exchange，在其 操作 列单击 详情。在 Exchange ...
- 产品推荐
- 这些文档可能帮助您