问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警,登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象:在 Group 详情 页面,看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹,单击 创建查询任务,...
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式,可根据本文提供的签名计算方式获取签名,再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述,如果选择签名校验模式,MQTT客户端实际连接MQTT消息服务器时,...
本文介绍如何在 云消息队列 Confluent 版 控制台中进行RBAC授权。背景信息 RBAC的全称是Role Based Access Control。RBAC的授权方式是基于角色进行授权的,而ACL是基于权限进行授权。因此,RBAC比ACL更适合批量授权以及权限回收。RBAC授权...
本文为您介绍快速使用 云消息队列 RabbitMQ 版 进行消息收发的操作流程。操作流程 后续步骤 步骤一:(可选)RAM用户授权 步骤二:创建资源 步骤三:调用SDK收发消息
当消费客户端出现Rebalance时,您可以查看Rebalance的详情,包括Rebalance的时间、耗时、次数、原因以及...后续步骤 当客户端频繁出现Rebalance时,您可以参考以下文档解决此问题:使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同,都是服务端根据消息设置的定时时间在某一固定时刻...
本文介绍使用 云消息队列 RocketMQ 版 提供的商业版HTTP协议的SDK收发消息时可能遇到的错误码,以及建议的处理方式。错误码 错误描述 HTTP状态码 建议处理方式 AccessDenied The OwnerId that your Access Key Id associated to is ...
在使用云消息队列 Kafka 版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权(sasl.mechanisms)...
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P,顾名思义,是一对一的消息收发模式,即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景,即...
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P,顾名思义,是一对一的消息收发模式,即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景,即...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
本文介绍使用 云消息队列 MQTT 版 云端SDK时的常见问题。使用云端SDK发送消息成功,为什么无法消费?云端SDK发送消息,只能使用终端SDK消费消息;或终端SDK发送消息,云端SDK消费消息,不支持云端SDK发送消息,云端SDK消费消息。终端SDK...
本产品(云消息队列 Kafka 版/2019-09-16)的OpenAPI采用 RPC 签名风格,签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK,开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用...
根据MQTT协议,Topic存在多级,定义第一级Topic为父级Topic,使用 云消息队列 MQTT 版 前,需先在控制台创建该父级Topic,可以在 云消息队列 MQTT 版 控制台创建,或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic(Subtopic)...
本文介绍如何使用 云消息队列 MQTT 版 的轨迹查询功能排查设备在线问题和消息收发问题。当设备的状态出现异常时,您可以使用设备轨迹查询功能,查询设备的连接历史;当消息的收发不符合预期时,您可以使用消息轨迹查询功能,查询消息的收发...
例如,您首次使用 云消息队列 RocketMQ 版 仪表盘功能时,系统会自动创建AliyunServiceRoleForOns服务关联角色。角色名称 角色权限策略 角色权限 AliyunServiceRoleForOns AliyunServiceRolePolicyForOns 云消息队列 RocketMQ 版 通过扮演...
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类,以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时,服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景,...
例如,您首次使用 云消息队列 RocketMQ 版 仪表盘功能时,系统会自动创建AliyunServiceRoleForOns服务关联角色。角色名称 角色权限策略 角色权限 AliyunServiceRoleForOns AliyunServiceRolePolicyForOns 云消息队列 RocketMQ 版 通过扮演...
云消息队列 MQTT 版 的Serverless实例购买成功后,默认为您预留固定规格的资源,若实际使用量超过预留规格,则按照实际使用量弹性计费,可以帮助您提高资源利用率并降低业务成本。重要 Serverless版实例购买后,无论是否使用实例都会开始按...
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类,以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时,服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景,...
使用 云消息队列 Kafka 版 时,可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况,以及处理方法。客户端消费流程 了解客户端消费流程,有助于理解消息是否堆积。一般情况下,客户端消费流程大致如下:判断消息...
根据MQTT协议,Topic存在多级,定义第一级Topic为父级Topic,在使用 云消息队列 MQTT 版 前,需先创建该父级Topic资源。注意事项 Topic不能跨实例使用,例如不能使用实例B的接入点订阅创建在实例A中的Topic。Topic名称长度限制为3~64个字符...
如果您想创建一个只有自己可见的队列,不允许其他用户访问,您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性,将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下:排他队列只对首次声明它的连接(Connection)可见,...
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构...使用限制 云消息队列 RabbitMQ 版 对集群、接口调用以及字符进行了限制,您在 云消息队列 RabbitMQ 版 时注意不要超过相应的限制值,以免程序出现异常。更多信息,请参见 使用限制。
使用 云消息队列 Kafka 版 提供默认值的配置项:plugin.path rest.advertised.port topic.creation.enable listeners 不会传输至Kafka Connect的配置项。sasl.*ssl.*security.*rest.advertised.host.name rest.advertised.listener rest....
本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
问题现象 所有Sarama Go版本客户端存在...如果发生了位点重置,产生大量堆积,您可以使用 云消息队列 Kafka 版 控制台提供的重置消费位点功能,手动重置消费位点到某一时间点,无需改代码或换Consumer Group。具体操作,请参见 重置消费位点。
问题现象 使用阿里云 云消息队列 Kafka 版 时,删除 Group 后,仍然收到消息堆积的告警信息。可能原因 发生消息堆积告警信息的原因如下:2.0.0以前的Kafka服务端版本,开源Kafka未提供删除 Group 和消费位点的OpenAPI,因此删除 Group,...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的,可以在多个线程之间共享使用。您可以在服务器上(或者多台服务器)部署多个生产者和消费者实例,也可以在同一个生产者或消费者实例里采用多线程发送或接收消息,从而提高...
更多信息,请参见 使用云消息队列 Kafka 版时出现消息堆积。相关文档 如果您希望通过API方式查询消费状态,请参见 GetConsumerProgress-查询消费组消费状态。如果您暂时不想处理堆积的消息,可以通过 重置消费位点 的方式跳过堆积消息。
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文以公网环境中的Java SDK为例说明...
本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK(Software Development Kit)即软件开发工具包,包含示例Demo、库文件、编译工具链以及编译脚本等,不需要开发者进行任何其他的配置,直接可以在SDK对应目录环境下,进行...
云消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;需要链路加密和消息鉴权,建议使用SSL...
使用限制 云消息队列 RabbitMQ 版 的查询时间限制在三天之内。云消息队列 RabbitMQ 版 支持最多查询100条消息。按Queue查询 登录 云消息队列 RabbitMQ 版 控制台,然后在左侧导航栏选择 实例列表。在 实例列表 页面的顶部菜单栏选择地域,...
本文描述云消息队列 RabbitMQ 版支持的所有系统权限策略及其对应的权限描述,供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合,可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制...
您可通过配置 云消息队列 MQTT 版 的数据流入规则来自定义数据从其他阿里云产品流入到 云消息队列 MQTT 版。本文介绍跨产品数据流入的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将...
您可通过配置 云消息队列 MQTT 版 的数据流出规则来自定义数据从 云消息队列 MQTT 版 流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息...
云消息队列 Kafka 版 提供全托管、免运维的迁移上云服务,用于自建实例或跨云云实例与 云消息队列 Kafka 版 实例之间的数据同步。本文介绍迁移上云的源实例类型、使用限制、跨VPC数据同步以及使用流程。前提条件 您已购买并部署 云消息队列...