本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 MQTT 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已创建 云消息队列 MQTT 版 实例...
而 云消息队列 RocketMQ 版 基于阿里云云原生自研的存储系统,支持所有实例按需按量使用存储空间,存储容量无上限约束。因此所有消息将严格按照约定的保存时间进行存储,无需担心因为存储空间不足消息被删除的情况出现。使用建议 消息存储...
前提条件 创建服务关联角色 角色名称:AliyunServiceRoleForAlikafka 角色策略名称:AliyunServiceRolePolicyForAlikafka 权限说明:允许 云消息队列 Kafka 版 使用该角色访问您的服务(云监控和ARMS服务)以完成云监控和仪表盘相关功能。...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 云消息队列 Kafka 版 中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源...
本文为您介绍 云消息队列 RabbitMQ 版 的应用场景,以便您更好地判断如何在业务中使用 云消息队列 RabbitMQ 版。异步解耦 云消息队列 RabbitMQ 版 可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再...
当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将 云消息队列 Kafka 版 接入阿里云Elasticsearch的操作方法。前提...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RabbitMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...
本文介绍 云消息队列 RocketMQ 版 中消息(Message)的定义、模型关系、内部属性、行为约束及使用建议。定义 消息是 云消息队列 RocketMQ 版 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ...
本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
云消息队列 Kafka 版 对某些具体指标进行了约束和规范,您在使用 云消息队列 Kafka 版 时注意不要超过相应的限制值,以免程序出现异常。重要 若由于您的实例配置超出使用限制导致的任何不稳定情况,不在SLA承诺和赔偿范围内。云消息队列 ...
使用 云消息队列 Kafka 版 时,可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况,以及处理方法。客户端消费流程 了解客户端消费流程,有助于理解消息是否堆积。一般情况下,客户端消费流程大致如下:判断消息...
本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次?为什么消息会一直重试?消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时,为什么子级Topic后会多了一个“/”?消息发送...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 Kafka 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 Kafka...
云消息队列 RabbitMQ 版 提供包年包月预付费和Serverless按量后付费计费方式,每种计费方式的计费项和计费规则都有所差异,您可以按照不同的使用场景和业务规模选择合适计费方式及实例类型,达到成本最优化的效果。实例类型和计费模式 说明...
本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下:channel.queuePurge("queue-name");
本文介绍 云消息队列 MQTT 版 提供的云端SDK和管控SDK的使用场景。使用说明 使用 云消息队列 MQTT 版 的云端SDK收发消息时,需要和终端SDK搭配使用。例如,使用云端SDK发送消息,终端SDK接收消息;或使用终端SDK发送消息,云端SDK接收消息...
如需使用客户端连接 云消息队列 Kafka 版 收发消息,您需要根据客户端的网络环境类型及传输的安全需要来配置接入点。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;同时需要链路...
本文主要为您介绍如何查看 云消息队列 RocketMQ 版 4.x系列标准版实例的费用明细,帮助您解决如下问题:如何查看每个Topic每天的费用明细和使用量?如何查看每个Topic计费项的资源包抵扣明细?如何查看每个Topic每小时的用量明细?为什么...
问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时,报QueueHasDiffField类型错误。例如QueueHasDiffField[OAutoDelete=false&NAutoDelete=true;说明 报错中O开头的参数的属性值为要调用的Queue的参数的已...
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM(Resource Access Management)实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKey ID和AccessKey Secret),按需为用户分配最小权限。本文介绍 云...
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时,为避免因磁盘容量不足而导致机器宕机,进而影响服务可用性,云消息队列 Kafka 版 会根据磁盘使用率的多少,执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范,您在使用 云消息队列 RocketMQ 版 时注意不要超过相应的限制值,以免程序出现异常。限制项 限制值 说明 Topic名称长度 64个字符 Topic名称长度不得超过该限制,否则会导致无法发送...
在调用TCP协议的SDK收发消息前,您需在 云消息队列 RocketMQ 版 控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件 开通消息队列服务并授权 背景信息 针对TCP和HTTP两种通信协议,云消息队列 RocketMQ 版 分别提供了多语言...
本文介绍 云消息队列 RocketMQ 版 中队列(MessageQueue)的定义、模型关系、内部属性、版本兼容性及使用建议。定义 队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器,也是 云消息队列 RocketMQ 版 消息的最小存储单元。云消息...
本产品(微消息队列 MQTT/2020-04-20)的OpenAPI采用 RPC 签名风格,签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK,开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
您可以在 云消息队列 Kafka 版 控制台创建实例、...云消息队列 Kafka 版 V3系列Serverless实例管理 V2系列实例管理 Topic Group Connector生态集成 迁移 权限管理 云消息队列 Confluent 版 集群资源规格评估 实例管理 权限管理 集群配置与使用
网络访问限制 在使用 云消息队列 RocketMQ 版 时,请注意以下网络访问限制:只有在同一个地域下的同一个实例中的Topic和Group ID才能互通,例如,某Topic创建在 华东1(杭州)地域的实例A中,那么该Topic只能被在 华东1(杭州)地域的实例A...
本文介绍如何使用数据清洗功能中的内容分割模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板,包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息,也可以根据业务情况在模板基础上修改代码。消息...
本文介绍通过两种协议的多语言SDK收发普通消息的流程和使用须知。背景信息 云消息队列 RocketMQ 版 提供了四种消息类型,更多信息,请参见 消息类型列表。本文以收发普通消息为例进行说明,因此,您按照本文提供的步骤创建的普通消息的...
问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时,报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields[ODurable=true&NDurable=false;说明 报错中O开头的参数的属性值为要调用的Exchange的...
消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。plain Mechanism string 否 加密方式。取值:SCRAM-SHA-512(默认选中)SCRAM-SHA-256 说明 该参数仅支持 V3 系列(Serverless)实例。SCRAM-SHA-256 返回参数 名称 类型 描述 示例...
使用 云消息队列 RocketMQ 版 进行消息收发,必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查看实例详情。背景信息 云消息队列 RocketMQ 版 实例按照规格分为标准版和企业...
本文介绍如何使用数据清洗功能中的内容映射模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板,包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息,也可以根据业务情况在模板基础上修改代码。消息...
消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram 返回参数 名称 类型 描述 示例值 object Code integer 状态码。返回 200 代表成功。200 Message string 返回信息。operation success RequestId string 请求 ID。3CB89F5C-CD...
如果您准备使用或正在使用 云消息队列 MQTT 版,有任何疑问和建议,欢迎您搜索钉钉群号 35228338加入钉钉群与我们交流。
消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Password string 密码。Username string 用户名。test12*示例 正常返回示例 JSON 格式 {"Code":200,"Message":"operation success.","RequestId":"9E3B3592-5994-4F65-A61E-E...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建消息流出任务 登录 云...
问题描述 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...