将云消息队列 Kafka 版接入阿里云Elasticsearch
云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。更...
配置消息队列Kafka版实例的参数
端口 填入 阿里云消息队列Kafka版 实例的服务端口，默认为9092。数据库账号 仅开启ACL的 阿里云消息队列Kafka版 实例才需要填写 数据库账号 和 数据库密码。说明 关于开启ACL的信息，请参见 SASL用户授权。请在 SASL用户管理 页签，查看 ...
关于HTTP服务不再支持经典网络的公告
为了提供更优质的服务质量，云消息队列 RocketMQ 版 提供的HTTP服务将于2021年05月31日后，不再支持经典网络ECS实例的访问。如果您的应用部署在经典网络ECS实例上，且访问的是 云消息队列 RocketMQ 版 的HTTP服务，请尽快将应用迁移到VPC...
关于HTTP服务不再支持跨地域访问的公告
例如您的 云消息队列 RocketMQ 版 实例在华东1（杭州）地域，则只能使用华东1（杭州）地域的接入点来访问该地域的实例。您可以实现以下场景的资源访问：如果您的客户端在华东1（杭州）地域，为了最佳体验，请使用该实例的HTTP内网接入点...
SetQueueAttributes
metaoverride=true HTTP/1.1 URI参数 metaoverride=true 将会修改消息队列的属性。特有Request Header 无。Request Body Request Body为XML格式，XML中包含创建Queue的属性，这些属性都为可选属性。参数名称 类型 是否必选 示例值 描述 ...
链上信息发布到消息队列
创建一个 RocketMQ消息队列实例，文中以实例“fabric-instance”，消息主题“event”为例。下载 云服务集成示例代码。本地安装 Node.js v8 环境（版本要求是V8.17.0及以上）。使用方法 在控制台创建云服务集成消息队列触发器，更多可以参考...
ListQueue
Name Value API ListQueue RAM授权操作 mns:ListQueue 资源 acs:mns:$region:$accountid:/queues 使用说明 调用该接口返回结果中只包含QueueURL属性，如需进一步获取消息队列的属性可以通过 GetQueueAttributes 接口获取。如果仅需要获取...
BatchSendMessage
发送消息时指定 DelaySeconds 参数的优先级高于延时消息队列的 DelaySeconds 属性，即两个 DelaySeconds 属性设置的值不同的时候以发送消息时指定的值为准。使用BatchSendMessage接口时，BatchSendMessage接口每秒最大并发请求数=限流比对...
主题与队列命名长度变更公告
自2021年01月13日起，新建的 消息服务MNS 主题或队列的命名长度不可超过120个字符，超过该限制会导致主题或队列创建失败。该限制不会影响在2021年01月13日前已创建的主题或队列，但会影响在2021年01月13日后新增的主题或队列。
服务支持
本文汇总了 云消息队列 Kafka 版 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议
Token应用服务器接口
本文介绍 云消息队列 MQTT 版 提供的应用服务器Token OpenAPI接口。API 描述 ApplyToken 调用 ApplyToken 申请临时访问的Token。QueryToken 调用 QueryToken 校验Token的有效性。RevokeToken 调用 RevokeToken 吊销Token。
Token应用服务器接口
本文介绍 云消息队列 MQTT 版 提供的应用服务器Token OpenAPI接口。OpenAPI 描述 ApplyToken 调用ApplyToken申请临时访问的Token。QueryToken 调用QueryToken校验Token的有效性。RevokeToken 调用RevokeToken吊销Token。
数据传输服务DTS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将数据传输服务DTS中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。在...
如何保证我的消息队列中的消息是安全的？
本文介绍阿里云如何保证消息队列中的消息是安全的。消息服务MNS 提供了安全可靠的身份验证机制，确保您的队列受到保护，防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列。
SmsUp
您可以通过MNS消息队列拉取短信上行消息（SmsUp）。前提条件 您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见 创建AccessKey。确保您可以在本地成功Ping以下三个地址：dysmsapi.aliyuncs.com或mns.cn-hangzhou.aliyuncs.com...
数据流入规则管理
注意事项 云消息队列 MQTT 版 通过配置的流入规则和 云消息队列 RocketMQ 版 进行跨云产品的消息交互时，若 云消息队列 RocketMQ 版 的服务端进行升级，则在升级期间，可能会造成 云消息队列 MQTT 版 客户端消费消息延迟。产品升级动态，请...
直播互动解决方案
Client ID 云消息队列 MQTT 版 的Client ID是每个客户端的唯一标识，要求全局唯一，使用相同的Client ID连接 云消息队列 MQTT 版 服务会被拒绝。Client ID由两部分组成，组织形式为<GroupID>@。Client ID的长度限制为64个字符，不允许使用...
数据流出规则管理
参数 取值示例 说明 目标服务类型 消息队列 RocketMQ 版 指定您需将源Topic的数据转发至的目标云产品。说明 当前仅支持 云消息队列 RocketMQ 版。RocketMQ 实例 MQ_INST_13801563067*_BbyOD2jQ 指定目标云产品的实例ID，即 云消息队列 ...
上下线通知规则管理
参数 取值示例 说明 目标服务类型 消息队列 RocketMQ 版 指定您需将 云消息队列 MQTT 版 客户端上下线通知流转至哪个目标云产品。说明 当前仅支持 云消息队列 RocketMQ 版。RocketMQ 实例 MQ_INST_13801563067*_BbyOD2jQ 指定目标云产品的...
新零售电子价签解决方案（MQTT）
电子价签后台管理服务部署在云端（云服务ECS），使用 云消息队列 RocketMQ 版 的SDK和 云消息队列 RocketMQ 版 交互。电子价签后台管理服务可以将改价等任务的状态变更持久化到RDS数据库以确保任务变更成功，并将价签上报数据和操作日志...
音视频通信解决方案（MQTT）
数据交互 数据流 所展示的是基于 云消息队列 MQTT 版 和音视频通信RTC实现一次音视频通话会议的调用流程，其中灰色部分为您的自建开发程序或服务，蓝色部分是 云消息队列 MQTT 版、云消息队列 RocketMQ 版 以及音视频通信RTC所提供的服务。...
内容分割
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
内容映射
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
名词解释
基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息队列 MQTT 版 前都需要在对应的地域（Region）创建一个实例，并使用对应的接入点来...
内容富化
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
动态路由
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
短轮询和长轮询
消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询 创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...
旧版本Token鉴权服务升级
云消息队列 MQTT 版 早期提供的Token鉴权服务即将于2020年12月31日下线，Token鉴权服务提供的Token服务接口已经迁移到新的云端服务网关。识别旧版本的Token鉴权服务 如果您获取Token的调用地址为 https://{tokenServerUrl}/token/apply ，...
创建MNS Sink Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 消息服务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您...
Token鉴权概述
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
创建MNS Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务，将 消息服务MNS 中的数据快速导入 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。...
Token鉴权概述
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 消息服务MNS 的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 消息服务MNS 中的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的消息流出至 消息服务MNS。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
一机一密概述
当设备与 云消息队列 MQTT 版 建立连接时，需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中，向 云消息队列 MQTT 版 发起认证请求，云消息队列 MQTT 版 认证通过后激活设备，设备与 云消息队列 MQTT 版 间才可传输...
集成概述
死信队列 支持 消息服务MNS 和 云消息队列 RocketMQ 版 等服务做死信队列。支持 云消息队列 Kafka 版 做死信队列。重试策略 统一支持。部分支持。依赖Kafka资源 不额外依赖。系统自动或手动创建任务位点Topic、任务配置Topic、任务状态...
- 产品推荐
- 这些文档可能帮助您