OnsTopicStatus-查询Topic状态
427EE49D-D762-41FB-8F3D-9BAC96C3*Data object 查询到的 Topic 的信息存储数据结构。Perm integer 所有关系编号。取值说明如下：2：可以发布 4：可以订阅 6：可以发布和订阅 6 LastTimeStamp long 当前 Topic 内最新一条消息的就绪时间，...
排他队列
因此，您在使用排他队列前请谨慎评估队列可能被自动删除的风险，并考虑队列数据丢失的场景。如何声明排他队列 排他队列在客户端程序中通过 channel.queueDeclare 方法声明，将 exclusive 设置为 true。以Java语言为例，声明方式如下：/*...
领域模型概述
云消息队列 RocketMQ 版 通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 RocketMQ 版 的最小传输单元。消息具备不可变性，在初始化发送和完成存储后即不可变。消息消费 消费者分组...
设置全局YARN资源队列
方式二：配置产品模块内YARN队列 数据开发（DataStudio）：对于Hive、Spark节点，可在节点编辑页面右侧导航栏的 高级设置，通过 queue 参数设置单个节点任务的YARN资源队列。数据质量：可在EMR表的分区规则中，通过 运行队列 配置单个分区...
支持的数据库
3.0 阿里云消息队列Kafka版 0.10.1.0~2.x版本 自建Kafka 0.10.1.0~2.7.0版本 库表结构同步 全量数据同步 增量数据同步 单向同步 PolarDB-X 2.0同步至阿里云消息队列Kafka DataHub 库表结构同步 增量数据同步 单向同步 PolarDB-X 2.0同步至...
同步方案概览
3.0 阿里云消息队列Kafka版 0.10.1.0~2.x版本 自建Kafka 0.10.1.0~2.7.0版本 库表结构同步 全量数据同步 增量数据同步 单向同步 PolarDB-X 2.0同步至阿里云消息队列Kafka DataHub 库表结构同步 增量数据同步 单向同步 PolarDB-X 2.0同步至...
队列（MessageQueue）
主题内队列数过多可能对导致如下问题：集群元数据膨胀 云消息队列 RocketMQ 版 会以队列粒度采集指标和监控数据，队列过多容易造成管控元数据膨胀。客户端压力过大 云消息队列 RocketMQ 版 的消息读写都是针对队列进行操作，队列过多容易...
迁移方案概览
全量数据迁移 增量数据迁移 PolarDB-X 2.0迁移至MaxCompute 阿里云消息队列Kafka版 0.10.1.0~2.x版本 自建Kafka 0.10.1.0~2.7.0版本 库表结构迁移 全量数据迁移 增量数据迁移 PolarDB-X 2.0迁移至阿里云消息队列Kafka DataHub 所有版本 ...
使用云数据库Redis版助力在线课堂应用
在线教育已经成为当下的热点行业之一，云数据库Redis版丰富的数据结构可以帮助您快速实现在线课堂应用的相关功能。背景信息 随着互联网直播的流行，直播已经走向了各行各业，老师使用直播应用进行线上教学也屡见不鲜，尤其是在2020年的新冠...
产品优势
数据持久化：专业团队保障更高可用性，消息持久化落盘到消息队列，数据可靠性高，服务可用性高。高吞吐能力：在海量消息堆积的情况下，始终能保持 云消息队列 Kafka 版 集群的高吞吐能力。数万级Topic：支持数万级Topic高并发读写，始终...
访问队列服务
当使用异步推理服务功能时，请求从输入队列返回，由EAS服务框架读取输出数据进行处理后将结果自动写入到输出队列中，服务框架会通过requestId这个tag将输入数据与输出数据进行关联，通过输入数据的requestId即可在输出队列中查询结果数据。...
数据流入规则管理
如需将其他阿里云产品的数据导入 云消息队列 MQTT 版，您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端，从而实现直接调用阿里云产品的API发送数据到MQTT客户端。流程说明 规则限制 ...
自建Oracle迁移至阿里云消息队列Kafka版
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle迁移至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源数据库和目标实例支持的版本，请参见 迁移方案概览...
数据流出规则管理
如需将 云消息队列 MQTT 版 的数据导出至其他阿里云产品，您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明 规则限制 限制项 限制...
跨云产品的数据流出
映射关系 MQTT资源 其他阿里云产品 其他阿里云产品资源 数据包定义 MQTT Topic 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 的Topic MQTT与RocketMQ的消息结构映射 更多信息 如需了解控制台上的操作，请参见 数据流出规则管理。
跨云产品数据流入
映射关系 MQTT资源 其他阿里云产品 其他阿里云产品资源 数据包定义 MQTT Topic 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 的Topic MQTT与RocketMQ的消息结构映射 更多信息 如需了解控制台上的操作，请参见 数据流入规则管理。
MQTT客户端上下线事件数据流出
映射关系 MQTT资源 其他阿里云产品 其他阿里云产品资源 数据包定义 MQTT Group ID 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 的Topic MQTT和RocketMQ的消息结构映射 操作流程 如上文所述，如果使用异步上下线通知的方式，您需创建...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
队列服务订阅推送
在订阅推送可以持续地将就绪的数据立即推送到客户端手中，避免通过Get API进行轮询造成的时延和通过队列服务的内部机制进行查询，可以最大程度地降低处理时延和队列服务的负载。但是在使用上，由于有较多额外的概念，订阅推送具有一定的...
上下线通知规则管理
说明 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 的消息结构映射信息，请参见 MQTT和RocketMQ的消息结构映射。编辑上下线通知规则 在规则列表，找到您想编辑的规则，并在其 操作 列选择 更多>编辑。在 编辑规则 页面，您可以更新除规则...
OnsTopicCreate-创建Topic
MQ_INST_188077086902*_BXSuW61e 返回参数 名称 类型 描述 示例值 object 返回的数据结构。RequestId string 公共参数，每个请求的 ID 都是唯一的，可用于排查和定位问题。B6949B58-223E-4B75-B4FE-7797C15E*示例 正常返回示例 JSON 格式 {...
收发延时消息
tag",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常...
收发定时消息
tag",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常...
发送消息（多线程）
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高...
发送普通消息（三种方式）
云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件 安装Java SDK。更多信息，请参见 ...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
收发顺序消息
TagA",/Message Body，任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务属性，请尽可能全局唯一。以方便您在无法...
收发顺序消息
TagA",/Message Body，可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。send order global msg".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
将云消息队列 Kafka 版的数据迁移至MaxCompute
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...
示例代码
TagA",/Message Body，任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务属性，请尽可能全局唯一。以方便您在无法...
在线教育视频直播
表格存储 表格存储（Tablestore）是阿里云自研的面向海量结构化数据存储的Serverless NoSQL多模型数据库，被广泛用于社交、物联网、人工智能、元数据和大数据等业务场景。提供兼容HBase的WideColumn模型、消息模型Timeline以及时空模型...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
集成概述
数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等操作。并支持将完成ETL处理的数据转储到下游。...
接入Logstash
数据从源传输到目标存储的过程中，Logstash过滤器能够解析各个事件，识别已命名的字段来构建结构，并将它们转换成通用格式，通过更轻松、快速的方式分析数据来实现商业价值。输出：导出数据。Logstash提供多种数据输出方向，灵活解锁众多...
什么是云消息队列 Confluent 版？
高SLA保障，数据持久化：专业团队保障更高可用性，消息持久化落盘到消息队列，数据可靠性高，服务可用性高。高吞吐能力：在海量消息堆积的情况下，始终能保持 云消息队列 Confluent 版 集群的高吞吐能力。全自动巡检运维体系保障，服务可用...
Kafka Connect
Converters 数据格式转换组件，用于在Kafka与外部服务之间进行消息数据的序列化以及反序列化操作，使得数据格式以及结构满足业务需求，Workers以及Connectors均可配置Converters，Connectors的Converter配置项可覆盖Workers的Converter配置...
将云消息队列 Kafka 版的数据迁移至MaxCompute
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
- 产品推荐
- 这些文档可能帮助您