数据标注
答：实体抽取目前支持的是内容较短的完整文本，并且不做推理。如果标注的内容是成多句或是成段的，建议您选择其它的项目/解决方案看看能否解决您的问题。标注太累了，我需要抽取的文本有好几种格式，能不能只标一种，能不能先标几条测测...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
Subscribe
FilterTag 否 描述了该订阅中消息过滤的标签（标签一致的消息才会被推送）。不超过16个字符的字符串，默认不进行消息过滤。NotifyStrategy 否 描述了向Endpoint推送消息出现错误时的重试策略。BACKOFF_RETRY或者 EXPONENTIAL_DECAY_RETRY，...
收发普通消息（三种方式）
阿里云 云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件 您已...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
概述
概念介绍—消息流出（Sink）消息流出的主要能力是将消息产品的数据流出到各类数据目标，消息集成模块对消息产品的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理（Transform）数据处理是消息集成的重要功能...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 联合 阿里云云监控 提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警 若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版 会进行强制限流。提前配置实例规格水位告...
名词解释
基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息队列 MQTT 版 前都需要在对应的地域（Region）创建一个实例，并使用对应的接入点来...
将云消息队列 Kafka 版接入阿里云Elasticsearch
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
步骤二：创建资源
一个新的应用接入 云消息队列 RabbitMQ 版 服务端，您需要提前创建 云消息队列 RabbitMQ 版 的相关资源，包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
服务关联角色
常见问题 为什么我的RAM用户无法自动创建消息队列RocketMQ版服务关联角色AliyunServiceRoleForOns？如果阿里云账号已经创建了服务关联角色，RAM用户就会继承该阿里云账号的服务关联角色。如果没有继承，请登录 RAM控制台 为其添加以下权限...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
服务关联角色
常见问题 为什么我的RAM用户无法自动创建 云消息队列 RocketMQ 版 服务关联角色AliyunServiceRoleForOns？如果阿里云账号已经创建了服务关联角色，RAM用户就会继承该阿里云账号的服务关联角色。如果没有继承，请登录 RAM控制台 为其添加...
上下线通知规则管理
在客户端上线和下线事件触发时，MQTT服务器会根据您配置的客户端上下线通知规则，向后端其他云产品推送一条上下线消息。业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。流程说明...
消费者分组（ConsumerGroup）
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
用户身份识别
使用限制 按量付费实例和包年包月实例使用用户身份识别功能需要 提交工单 申请开通，申请通过后控制台才会出现访问控制的操作入口。功能原理 云消息队列 RocketMQ 版 的访问控制支持智能身份识别和ACL身份识别两种类型，云消息队列 ...
音视频通信解决方案（MQTT）
音视频管控服务收到参数后将参数封装成邀请入会的消息，发送到 云消息队列 RocketMQ 版，经过 云消息队列 MQTT 版 路由后消息会投递给发起者用户A使用的终端App，用户A的终端App根据参数加入会议频道完成入会操作。音视频管控服务还需要...
自动创建Topic
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且该实例必须满足以下条件：项目 说明 状态 服务中 版本 大版本为2.2.0或以上版本，小版本为最新版本。说明 您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面的 基础信息 区域查看...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
自动创建Topic
自动创建Topic是指当 云消息队列 Kafka 版 实例发送请求以获取不存在的Topic元数据时，例如向不存在的Topic发送生产请求，云消息队列 Kafka 版 可以自动创建Topic。自动创建Topic适用于迁移上云场景或测试场景，无需手动重复创建Topic，...
应用场景
与传统架构不同，云消息队列 Kafka 版 以及Storm、Samza、Spark等数据处理引擎的出现，就是为了更好地解决这类数据在处理过程中遇到的问题，数据处理模型能实现在数据流动的过程中对数据进行实时地捕捉和处理，并根据业务需求进行计算分析...
客户端连接常见问题
本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述 资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因 接入点格式不正确，正确...
查看实例风险
Topic 格式转换 同步发送问题 碎片化发送问题 单分区Topic风险 Topic分区倾斜问题 生产流量 分区数量配额 分区分配策略问题 Group 消费消息接收耗时 消费消息排队耗时 消费消息读磁盘耗时 消费消息读磁盘耗时 消费消息格式转换时间 Group...
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
自由使用Group
注意事项 在生产环境，长期开启自由使用Group的功能，可能会由于客户端使用不当出现资源随意使用，导致运维成本增加，并且极易造成系统不稳定，建议您通过 云消息队列 Kafka 版 控制台或者调用OpenAPI手动创建Group，进行统一管理。...
自动化创建Topic相关问题
本文汇总了 云消息队列 Kafka 版 关于自动创建Topic的相关问题。是否可以自动化创建Topic？可以，但不建议。云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不支持也不建议自动化创建Topic，主要原因如下：自动化创建...
集成概述
概念介绍—消息流出（Sink）消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标，Connector生态集成模块对 云消息队列 Kafka 版 的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理...
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
计费FAQ
我没有使用云消息队列 RabbitMQ 版服务，为什么会扣费？请登录 费用管理中心 查看账单，检查您是否有使用 云消息队列 RabbitMQ 版 服务。如果您不需要使用 云消息队列 RabbitMQ 版 服务，请及时删除 云消息队列 RabbitMQ 版 控制台上所有...
计费FAQ
我没有使用云消息队列 RabbitMQ 版服务，为什么会扣费？请登录 费用管理中心 查看账单，检查您是否有使用 云消息队列 RabbitMQ 版 服务。如果您不需要使用 云消息队列 RabbitMQ 版 服务，请及时删除 云消息队列 RabbitMQ 版 控制台上所有...
常见问题
本文汇总了使用 Chat App 消息服务 时的常见问题。WABA注册界面的注册按钮灰色，不可点击？为保证用户快速完成注册，Chat App 会自动检测与Meta的网络连接。当注册按钮为灰色时，说明用户与Meta之间的网络连接不可用，请登录Meta官网检查...
新功能发布记录
本文介绍 云消息队列 Kafka 版 的产品功能动态及对应的文档。2024-04-15 功能名称 功能描述 功能类型 相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服 云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
OnsTopicCreate-创建Topic
取值说明如下：0：普通消息 1：分区顺序消息 2：全局顺序消息 4：事务消息 5：定时/延时消息 各类型消息的详细说明，请参见 消息类型列表。0 Remark string 否 需创建的 Topic 的描述信息。测试 InstanceId string 是 需创建的 Topic 所...
- 产品推荐
- 这些文档可能帮助您