功能与特性概述
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：...
主题模型快速入门
可选：在消息列表中找到目标消息，在其右侧 操作 列单击 详情，在 消息详情 对话框中查看消息内容等信息。删除队列 在 队列列表 页面，找到目标队列，在其右侧 操作 列选择 更多>删除。在 提示 对话框中，阅读提示信息，然后单击 确认。...
作为Output接入
步骤四：查看Topic分区 查看消息发送到Topic的情况。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击作为Output接入Logstash的实例。在左侧导航栏，单击 Topic 管理。在 Topic 管理 ...
作为Output接入
步骤四：查看Topic分区 查看消息发送到Topic的情况。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 Topic 管理。在 Topic 管理 页面，找到目标Topic...
API概览
当消息的收发不符合预期时，您可以通过该接口查看订阅该消息的客户端、消息的投递时间等详细信息，帮助您快速定位异常原因。CA证书 API 标题 API概述 RegisterCaCertificate 注册CA证书 云消息队列 MQTT 版支持X.509证书认证，客户端可通过...
API概览
消息 API 标题 API概述 OnsMessageTrace 查看消息消费结果 调用OnsMessageTrace根据Message ID来判断目标消息是否曾被消费过。OnsMessageGetByMsgId 通过MsgId查询消息 通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾...
作为Output接入
步骤四：查看Topic分区 查看消息发送到Topic的情况。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 Topic 管理。在 Topic 管理 页面，找到目标Topic...
开源对比
查询消息 控制台根据时间或者位点直接查看消息。命令行可以消费，但无法根据位点或者时间直接定位到具体的消息。使用习惯 云消息队列 Kafka 版 在客户端协议层面和开源Apache Kafka完全一致，因此基于开源版本开发的应用和代码可以无缝迁移...
作为Output接入
步骤四：查看Topic分区 查看消息发送到Topic的情况。登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，单击 Topic 管理。在 Topic 管理 页面，找到目标Topic...
通过创建自定义规则实现OSS事件通知
本文介绍如何通过创建自定义规则实现OSS事件通知。前提条件 开通消息服务MNS并授权 注意事项 事件通知规则创建完成后，约10分钟生效。...在消息列表中，找到目标消息，在其右侧 操作 列单击 详情，在 消息详情 对话框中查看消息内容。
如何快速测试云消息队列 Kafka 版服务端是否正常？
操作流程 快速测试 云消息队列 Kafka 版 服务端的流程如下：创建Topic 发送消息 查看分区状态 按位点查询消息 您可以多次重复步骤2到步骤4，如果多次操作正常，则说明服务端正常。说明 如果服务端正常，但发送消息依然失败，建议您去调用方...
创建OSS Sink Connector（旧版）
本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。...打开下载的文件，查看消息内容。如图所示，多条消息之间通过换行分隔。
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
消费重试
查看消费重试日志 PushConsumer顺序消费的重试是在消费者客户端进行，服务端无法获取消费重试的详细日志，若消息轨迹中顺序消息的投递结果为失败时，您需要在消费者客户端日志中查看消息重试的最大次数、消费者客户端等信息。消费者客户端...
创建OSS Sink Connector（新版）
本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。...打开下载的文件，查看消息内容。如图所示，多条消息之间通过换行分隔。
步骤三：调用SDK收发消息
验证消息 消息收发完成后，您可以通过控制台查看消息消费情况。登录 控制台，在 实例列表 页面选择目标实例。在左侧导航栏单击 消息轨迹。SDK参考 本文以Java SDK为例介绍收发普通消息流程，其他语言SDK和其他类型消息的示例代码，请参见 ...
数据出口
Link WAN支持通过阿里云物联网平台流转数据，也支持用户自建云服务流转数据。数据出口至 物联网平台控制台，...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic，数据流转至自建云服务
查看应用拓扑图
MQ（消息队列），代表当前节点为 MQ 应用，不支持查看节点的监控概览信息。DB（数据库），代表当前节点为 DB 应用，不支持查看节点的监控概览信息。Cache（缓存），代表当前节点为缓存应用，不支持查看节点的监控概览信息。应用节点连线，...
云消息队列 RocketMQ 版服务等级协议
如需查看 云消息队列 RocketMQ 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 RocketMQ 版服务等级协议。
云消息队列 RabbitMQ 版服务等级协议
如需查看 云消息队列 RabbitMQ 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 RabbitMQ 版服务等级协议。
微消息队列MQTT版服务等级协议
云消息队列 MQTT 版 提供的服务可用性等级指标及赔偿方案，请查看 微消息队列MQTT版服务等级协议。
云消息队列 Kafka 版服务等级协议
云消息队列 Kafka 版 规定了阿里云向客户提供的阿里云 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案。如需查看 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 Kafka 版服务等级协议。
为什么Topic有分区时间显示1970或“-”？
问题现象 Topic的分区更新时间显示为1970或者为“-”。可能原因 出现此问题的原因可能...如果是Local存储引擎，您可以使用消息查询功能查看正确消息生产时间。如果是云存储引擎，并且缓存过期，您可以使用消息查询功能查看正确消息生产时间。
查看消息
查看和管理消息 查看消息 实时消息 在实时消息面板直接单击消息卡片，可展开消息的详细内容，单击 我知道了 或 图标可关闭消息卡片。实时消息自动不显示或关闭后，可在消息中心进行查看。消息中心 在云电脑内打开悬浮球，单击 消息。在 ...
TCC 模式接入注意事项
1:AT 2:MT 3:AT&MT-><constructor-arg value="2"/></bean>GTS 对 MQ 事务消息纳入全局事务管理的支持是通过 TCC 模式实现的。所以，使用 AT 模式的同时，又需要把 MQ 事务消息纳入全局事务管理时，就需要同时开启 AT 和 TCC 模式的配置。...
消息轨迹查询
当消息的收发不符合预期时，您可以使用消息轨迹查询功能...您可以在查询结果列表中单击 操作 列的 消息轨迹 查看指定消息的消息轨迹。相关文档 如果需要查询设备的状态，请参见 设备状态查询。如果需要查询设备的轨迹，请参见 设备轨迹查询。
支持STS的云服务
控制台 API 企业级分布式应用服务-edas√消息队列MQ 消息队列Rocket MQ版 mq√消息队列MQ 微消息队列MQTT版 mq√消息队列MQ 消息队列RabbitMQ版 amqp√云服务总线CSB-csb√性能测试-pts√消息服务-mns√应用配置管理-acms√消息队列Kafka版...
消息队列MQ的审计事件
消息队列MQ（AMQP）已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列MQ产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录了...
消息查询
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...
版本说明
mq-http-csharp-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持顺序消息。支持使用Message ID查询消息轨迹。支持消息属性。mq-...
版本说明
1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-http-cpp-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持顺序消息。支持使用Message ID查询...
版本说明
1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-http-nodejs-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持顺序消息。支持使用Message ID...
版本说明
mq-http-java-sdk-1.0.3.zip 1.0.2 发布时间 发布内容 下载 2020-01-15 功能优化 更新Log4j至Log4j 2。mq-http-sdk-1.0.2.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持...
版本说明
1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-http-python-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持顺序消息。支持使用Message ID...
日志管理概述
日志查看：查看日志。在为LogStore创建索引时，请选择合理的数据保存时间，该属性后续只支持缩短，不支持延长。如果您将LoggingBucket对应的 SLS 的Project、LogStore删除，或者将授予 消息服务MNS 的权限取消，日志将无法正常推送。日志...
迁移数据上云
bin/kafka-consumer-groups.sh-new-consumer-describe-bootstrap-server自建集群接入点-group test-consumer-group 往自建集群中发送消息，在 云消息队列 Kafka 版 控制台中查看Topic的分区状态，确认当前服务器上消息总量是否正确。...
Group管理
Group表示一类Producer或Consumer，这类Producer或Consumer通常生产或消费同一类消息，且消息发布或订阅的逻辑一致。使用 云消息队列 RocketMQ 版 进行消息收发，您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文...
数据出口至消息队列MQ
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ，本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组，单击一条节点分组对应 操作 栏下的...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
canal.instance.dbUsername=*canal.instance.dbPassword=*.#mq config#您在云消息队列 Kafka 版控制台创建的Topic。canal.mq.topic=mysql_test#针对数据库名或者表名发送动态Topic。canal.mq.dynamicTopic=mytest,.*,mytest.user,mytest\\....
sample-txc-mq 样例
本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件 在使用 sample-txc-mq 样例前，请先完成以下工作：开通 GTS（创建事务分组）。开通 MQ。...可以消费掉刚刚 sample-txc-mq 工程生产出来的 MQ 消息。
- 产品推荐
- 这些文档可能帮助您