迁移上云
使用限制 云消息队列 Kafka 版 对迁移上云任务的限制如下：项目 限制值 数量 单实例最多创建20个迁移任务。在单实例中迁移上云与Connector资源共享。规格类型 创建实例迁移任务时，实例的规格类型需为 专业版（高写版）或 专业版（高读版）...
OnsTopicCreate-创建Topic
调用OnsTopicCreate接口创建Topic。...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTopicCreate 接口，您还可以通过消息队列 RocketMQ 版控制台，创建 Topic。具体操作，请参见 Topic 管理。
数据流入规则管理
如需将其他阿里云产品的数据导入 云消息队列 MQTT 版，您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端，从而实现直接调用阿里云产品的API发送数据到MQTT客户端。流程说明 规则限制 ...
创建Elasticsearch Sink Connector
本文介绍如何创建Elasticsearch Sink Connector，您可以通过Elasticsearch Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至阿里云Elasticsearch中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 在...
上下线通知规则管理
例如，创建数据流出规则，数据源 云消息队列 MQTT 版 实例属于华东1（杭州）地域，则数据目标 云消息队列 RocketMQ 版 只能选择华东1（杭州）地域的实例。云消息队列 MQTT 版 实例版本 仅内核版本为V3.x.x的实例支持使用规则，V2.x.x的实例...
监控报警
云监控服务具有指标采集、可视化、实时报警等功能，云消息队列 RocketMQ 版 支持通过云监控创建监控规则，帮助您自动监控服务的运行状态，并自动发送报警通知，便于您及时预警服务的异常信息，提高运维效率。监控项说明 说明 消息堆积量、...
数据流出规则管理
如需将 云消息队列 MQTT 版 的数据导出至其他阿里云产品，您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明 规则限制 限制项 限制...
自由使用Group
打开自由使用Group的开关表示 云消息队列 Kafka 版 允许未在控制台创建的Group可以调用API进行消息消费和位点提交等操作，如果关闭自由使用Group功能，那么未在控制台创建的Group（即控制台上 自动创建 栏显示为 是 的Group）将无法进行...
创建SLS Sink Connector
本文介绍如何创建使用SLS Sink Connector，您可通过SLS Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至日志服务SLS。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 创建日志项目（Project）。详细...
监控报警
云消息队列 RocketMQ 版 支持通过云监控创建监控规则，帮助您自动监控服务的运行状态，并自动发送报警通知，便于您及时预警服务的异常信息，提高运维效率。云监控服务的详细信息，请参见 云产品监控。监控项说明 说明 已就绪消息量 和 已...
自动创建Topic
云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，不建议在生产环境中开启自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过...
创建OSS Sink Connector（旧版）
本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 在对象存储OSS控制台...
监控报警
云监控服务具有指标采集、可视化、实时报警等功能，云消息队列 MQTT 版 支持通过云监控创建告警规则，帮助您自动监控服务的运行状态，并自动发送报警通知，便于您及时预警服务的异常信息，提高运维效率。监控项说明 说明 云监控中统计的...
创建MaxCompute Sink Connector
本文介绍如何创建使用MaxCompute Sink Connector，您可以通过MaxCompute Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至MaxCompute的表中。前提条件 详细步骤，请参见 创建前提。注意事项 如需使用MaxCompute分区...
创建OSS Sink Connector（新版）
本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。前提条件 详细步骤，请参见 创建前提。注意事项 Connector基于事件被处理的时间做时间...
创建AnalyticDB Sink Connector
本文介绍如何创建使用AnalyticDB Sink Connector，您可通过AnalyticDB Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至AnalyticDB的表中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 创建 云原生...
创建Tablestore Sink Connector
本文介绍如何创建使用Tablestore Sink Connector，您可通过Tablestore Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至Tablestore的表中。前提条件 创建资源及授权策略，请参见 创建前提。创建Connector时生成的函数...
服务关联角色
在自动创建服务关联角色失败或 云消息队列 RocketMQ 版 不支持自动创建时，您需要手动创建服务关联角色。背景信息 阿里云访问控制为每个服务关联角色提供了一个系统权限策略，该策略不支持修改。如果您想了解该系统策略的具体内容，可前往...
CreateVirtualHost
调用CreateVirtualHost创建Vhost。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...
基本概念
创建Topic时队列由系统自动分配，不支持自定义修改。集群消费 一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在集群消费模式下每个实例平均分摊，只消费其中的3条消息。...
使用Canal和RocketMQ实现数据库变更订阅处理
实例创建，请参见 创建消息队列RocketMQ版实例。处于运行中的MySQL实例。本文以阿里云RDS MySQL为例，实例创建，请参见 创建RDS MySQL实例。用于部署运行Canal相关组件的机器。网络要求 部署canal-deployer（server）的节点可以连接数据库...
使用Canal和RocketMQ实现数据库变更订阅处理
实例创建，请参见 创建消息队列RocketMQ版实例。处于运行中的MySQL实例。本文以阿里云RDS MySQL为例，实例创建，请参见 创建RDS MySQL实例。用于部署运行Canal相关组件的机器。网络要求 部署canal-deployer（server）的节点可以连接数据库...
主题（Topic）
取值：系统根据队列数量给主题分配队列，队列数量创建主题时定义。约束：一个主题内至少包含一个队列。消息类型 定义：主题所支持的消息类型。取值：创建主题时选择消息类型。云消息队列 RocketMQ 版 支持的主题类型如下：Normal：普通消息...
CREATE QUEUE TABLE
创建新的队列表。语法 CREATE QUEUE TABLE name OF type_name[({ option_name option_value }[,.])]其中 option_name 和对应的 option_value 可以是：option_name option_value SORT_LIST priority,enq_time MULTIPLE_CONSUMERS FALSE,TRUE...
迁移上云操作
前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称：AliyunServiceRoleForRMQMigration 权限策略：AliyunServiceRolePolicyForRMQMigration 权限说明：允许 云消息队列 RocketMQ 版 使用该角色获取访问专有网络VPC的...
CreateConsumerGroup-创建消费组
调用CreateConsumerGroup创建Group。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 ...
操作指南
您可以在 云消息队列 RocketMQ 版 控制台管理实例、Topic、Group等资源，并进行消息轨迹查询、创建云监控等运维操作。云消息队列 RocketMQ 版5.x系列 资源管理 迁移上云 版本管理 消息轨迹 监控报警 其他更多操作，请参见 5.x系列操作指南...
EnableAutoTopicCreation-开启自动创建 Topic
本文介绍如何调用 EnableAutoTopicCreation 开启和关闭自动创建Topic，以及修改自动创建 Topic 默认分区数。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例...
使用Terraform管理SASL用户
如果需要更细致的权限控制，您需开启ACL，创建SASL用户，按需赋予SASL用户向 云消息队列 Kafka 版 收发消息的权限。使用Terraform的 alicloud_alikafka_sasl_user 资源可以创建和管理SASL用户。前提条件 安装Terraform。支持Terraform 0.13...
CreateAcl-创建ACL
调用CreateAcl创建ACL。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中...
RAM鉴权
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。在使用...
CreateGroupId
调用CreateGroupId创建Group ID。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...
CreateTopic-创建Topic
创建Topic。接口说明 单用户请求频率限制为 1 QPS。每个实例下最多可创建的 Topic 数量与您所购买的实例规格相关。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK...
CreateExchange
调用CreateExchange创建Exchange。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...
CreatePostPayOrder-创建后付费实例
本文介绍如何调用CreatePostPayOrder创建后付费实例。接口说明 请确保在使用该接口前，已充分了解后付费实例的收费方式和价格。更多信息，请参见 计费说明。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行...
ApplyToken-创建临时访问 Token
说明 云消息队列 MQTT 版支持匹配子级 Topic，子级 Topic 无需在控制台创建，直接在消息收发代码中设置即可。Topic 名称中的正斜线（/）用于分隔父级 Topic 和各子级 Topic。更多信息，请参见 基本概念。TopicA/InstanceId string 是 云...
CreatePrePayOrder-创建预付费实例
本文介绍调用CreatePrePayOrder创建预付费实例。接口说明 请确保在使用该接口前，已充分了解预付费实例的收费方式和价格。更多信息，请参见 计费说明。使用该接口后，购买的预付费实例默认购买时长为一个月，并且默认开通了自动续费，自动...
使用Terraform管理Kafka Consumer Group
前提条件 已购买和部署云消息队列 Kafka 版实例。安装Terraform。支持Terraform 0.13及以上版本。方式一：在Cloud Shell中使用Terraform。方式二：在本地安装和配置Terraform。配置阿里云账号信息。选择一种阿里云认证方式，为Terraform的...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
CreateSaslUser-创建SASL用户
调用CreateSaslUser创建SASL用户。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 ...
- 产品推荐
- 这些文档可能帮助您