本文为您介绍使用 云消息队列 Kafka 版 时出现 Not ...在云消息队列 Kafka 版的控制台创建Consumer Group。具体步骤，请参见 创建Consumer Group。调用管控API创建Consumer Group。具体详情，请参见 CreateConsumerGroup-创建消费组。
本文为您介绍使用 云消息队列 Kafka 版 时出现 Not ...在云消息队列 Kafka 版的控制台创建Consumer Group。具体步骤，请参见 创建Consumer Group。调用管控API创建Consumer Group。具体详情，请参见 CreateConsumerGroup-创建消费组。
步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，单击 创建主题。在 创建主题 面板，配置以下参数，然后单击 确定。名称：主题名称。消息最大长度...
注意事项 在生产环境，长期开启自由使用Group的功能，可能会由于客户端使用不当出现资源随意使用，导致运维成本增加，并且极易造成系统不稳定，建议您通过 云消息队列 Kafka 版 控制台或者调用OpenAPI手动创建Group，进行统一管理。...
本文介绍如何使用C#SDK中的sample代码，完成创建主题、创建队列、创建订阅和发布消息等操作。步骤一：准备工作 下载最新版C#SDK，解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS，右击项目名，选择重新...
云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，不建议在生产环境中开启自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过...
本文介绍如何创建使用Tablestore Sink Connector，您可通过Tablestore Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至Tablestore的表中。前提条件 已开通表格存储服务并创建实例。具体操作，请参见 开通服务和创建...
创建私网连接接入点后，您可以在创建私网连接接入点时指定的VPC内通过私网连接访问 云消息队列 RabbitMQ 版 资源收发消息。应用场景 使用私网连接接入点指定VPC访问 云消息队列 RabbitMQ 版 适合用于以下场景：实例型产品访问网络时需要对...
本文介绍如何创建Elasticsearch Sink Connector，您可以通过Elasticsearch Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至阿里云Elasticsearch中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 在...
本文介绍如何创建使用SLS Sink Connector，您可通过SLS Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至日志服务SLS。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 创建日志项目（Project）。详细...
本文介绍如何使用PHP SDK创建主题、创建队列、创建订阅和发布消息等操作。步骤一：准备工作 下载文件 CreateTopicAndPushMessageToQueue。打开 CreateTopicAndPushMessageToQueue.php 文件，在文件中最下方配置以下内容：AccessKey ID、...
本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。前提条件 详细步骤，请参见 创建前提。注意事项 Connector基于事件被处理的时间做时间...
本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 在对象存储OSS控制台...
本文介绍如何创建使用AnalyticDB Sink Connector，您可通过AnalyticDB Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至AnalyticDB的表中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 创建 云原生...
轻量消息队列（原 MNS）支持使用队列模型和主题模型收发消息，实现一对一或者一对多的消费模式，本文以简单明了的方式让您快速上手 轻量消息队列（原 MNS）。背景信息 轻量消息队列（原 MNS）提供队列模型和主题模型。队列模型：支持一对一...
变更说明 由于 新版本 的 云消息队列 MQTT 版 实现了自身的消息存储，因此 云消息队列 MQTT 版 实例购买开通后即可直接创建资源使用，无需和任何其他云产品绑定使用。如您只需使用MQTT协议来收发消息，则更容易理解。变更说明的详细信息，...
本文介绍如何使用Python SDK中的sample代码，完成创建主题、创建队列、创建订阅、发布消息和删除主题等操作。步骤一：准备工作 下载最新版Python SDK，解压后进入 mns_python_sdk 子目录。本文示例代码以Python 2.x为例。打开 sample.cfg ...
项目 云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式 云消息队列 Kafka 版 控制台 云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建 云消息队列 Kafka 版 默认通过阿里云控制...
网络访问设置 您在创建 云消息队列 Confluent 版 集群时，除Control Center默认开公网外，其他组件公网默认不开，实例创建成功后可在 实例详情 页面的 访问链接与接口 页面开启其他组件的公网。云消息队列 Confluent 版集群各类型网络域名 ...
本文介绍如何创建使用MaxCompute Sink Connector，您可以通过MaxCompute Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至MaxCompute的表中。前提条件 详细步骤，请参见 创建前提。注意事项 如需使用MaxCompute分区...
您可以使用 云消息队列 Confluent 版 的日志管理功能将 云消息队列 Confluent 版 实例的消息操作日志推送到日志服务。您可通过开通该服务，查询客户端的所有请求日志。前提条件 创建 云消息队列 Confluent 版 实例。具体操作，请参见 购买...
Queue API 标题 API概述 CreateQueue 创建Queue Queue是指消息队列，云消息队列 RabbitMQ 版的消息都会被发送至指定的Exchange，再由Exchange路由至绑定的Queue中。DeleteQueue 删除 Queue 删除Queue。ListQueueConsumers 查询Queue的消费...
说明 如果您使用 RAM 用户的 AccessKey 创建的静态用户名密码接入消息队列 RabbitMQ 版并收发消息，请确保该 RAM 用户已被授予收发消息权限。更多信息，请参见 RAM 权限策略。yourAccessKeyID userName string 是 待创建的静态用户名。该...
下图以创建订单为例对比传统事务和 云消息队列 RocketMQ 版 事务消息的方案：分布式定时/延时调度 云消息队列 RocketMQ 版 提供精确度到秒级的分布式 定时消息 能力，可广泛应用于订单超时中心处理、分布式延时调度系统等场景。使用 云消息...
云消息队列 RabbitMQ 版 具有丰富的安全防护能力，通过多项合规认证，支持存储加密、传输加密等安全特性。为您的云端数据安全进行全方位的保驾护航，并满足您企业数据的安全与合规要求。存储加密 功能说明 云消息队列 RabbitMQ 版 支持在...
步骤一：创建云消息队列 MQTT 版资源 创建实例 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标地域，然后在页面左上角单击 创建实例。在弹出的付费方式面板中，选择按需选择 包年包月 或 Serverless ...
新增 查看实例风险 管理预警联系人 2022-03-15 功能名称 功能描述 功能类型 相关文档 迁移上云 云消息队列 Kafka 版 控制台 迁移上云 操作优化，支持创建迁移任务，将自建Kafka集群迁移至 云消息队列 Kafka 版 实例，为您提供更好的迁移...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用 云消息队列 MQTT 版 前，需先在控制台创建该父级Topic，可以在 云消息队列 MQTT 版 控制台创建，或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic（Subtopic）...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息队列 MQTT 版 前都需要在对应的地域（Region）创建一个实例，并使用对应的接入点来...
使用 云消息队列 RocketMQ 版 进行消息收发，必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查看实例详情。背景信息 云消息队列 RocketMQ 版 实例按照规格分为标准版和企业...
云消息队列 MQTT 版 提供容灾功能，旨在帮助您在网络波动、机房故障或其他不可预见的灾难场景下，快速将MQTT流量切换到备用实例，从而提升服务的抗风险能力和可用性。本文为您介绍容灾的功能说明、工作原理、权限说明及容灾切换方式。背景...
创建私网连接接入点后，原内网接入点仍可正常访问 轻量消息队列（原 MNS）服务。费用说明 PrivateLink 开通时不产生费用。开通成功后，根据实际使用量进行计费，按小时出账。费用包含实例费和流量处理费。更多信息，请参见 计费说明。...
说明 云消息队列 MQTT 版支持匹配子级 Topic，子级 Topic 无需在控制台创建，直接在消息收发代码中设置即可。Topic 名称中的正斜线（/）用于分隔父级 Topic 和各子级 Topic。更多信息，请参见 基本概念。TopicA/InstanceId string 是 云...
版本支持策略 实例创建 云消息队列 Kafka 版 实例目前支持2.2.0，2.6.2和3.3.1版本的创建。由于客户端版本保持向前兼容，默认支持最新版本的创建。实例升级 版本升级功能目前仅支持向前升级，且不支持回退版本。版本升级路径如下：技术支持...
前提条件 创建 云消息队列 RabbitMQ 版 实例。具体操作，请参见 实例管理。开通 日志服务 并创建Project和Logstore。具体操作，请参见 存储资源层级关系说明。根据控制台提示创建RabbitMQ服务关联角色 AliyunServiceRoleForAmqpLogDelivery...
本文以 云消息队列 Kafka 版 作为事件源为例，介绍如何在 事件总线EventBridge 控制台添加 表格存储（Tablestore）作为事件流中的事件目标以实现将 云消息队列 Kafka 版 中的消息写入到 表格存储（Tablestore）中进行数据存储和管理。...
云消息队列 RocketMQ 版 提供消息数据存储加密、传输加密等安全特性，有效地防止未授权访问、数据泄露以及在传输过程中被拦截或篡改的风险。存储加密 加密原理 云消息队列 RocketMQ 版 支持在服务器端对消息数据进行加密。客户端发送消息...