什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，包括该连接下所有建立的Channel。其他连接无法声明相同名称的排他队列，且其他连接以及连接下的Channel都无法访问该排他队列。连接断开时排他性...
本文介绍 云消息队列 Kafka 版 的产品动态、产品简介及产品计费。云消息队列 Kafka 版 动态与公告 产品简介 产品计费 云消息队列 Confluent 版 什么是云消息队列 Confluent 版？产品计费
虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云消息队列 RabbitMQ 版 保持连接，即代码逻辑层面还在主动发起连接到 云消息队列 RabbitMQ 版 的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...
虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云消息队列 RabbitMQ 版 保持连接，即代码逻辑层面还在主动发起连接到 云消息队列 RabbitMQ 版 的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...
更多信息，请参见 什么是云消息队列 Kafka 版。阿里云Elasticsearch Elasticsearch简称ES，是一个基于Lucene的实时分布式的搜索与分析引擎，是遵从Apache开源条款的一款开源产品，是当前主流的企业级搜索引擎。它提供了一个分布式服务，...
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
触发条件 云消息队列 RocketMQ 版 的消息流控触发条件如下：存储压力大：参考 消费进度管理 的原理机制，消费者分组的初始消费位点为当前队列的最大消费位点。若某些场景例如业务上新等需要回溯到指定时刻前开始消费，此时队列的存储压力会...
更多信息，请参见 什么是云消息队列 Kafka 版？ZooKeeper 一款开源的分布式应用程序协调服务。在 云消息队列 Kafka 版 中，ZooKeeper主要用于集群管理、配置管理、Leader选举。ZooKeeper是 云消息队列 Kafka 版 的一部分，您无需感知...
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
更多有关消息服务MNS的详细介绍，请参见 什么是消息服务MNS。MNS回调机制 您需要在消息服务MNS中创建队列，并在视频点播中配置相应回调。当事件产生时，视频点播服务会将事件通知内容写入到消息服务MNS的消息队列中。只要视频点播服务将...
微消息队列MQTT版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKeyId和AccessKeySecret），按需为用户分配最小权限。在使用RAM账号...
云消息队列 MQTT 版 的详细介绍，请参见 什么是微消息队列MQTT版 和 名词解释。消息结构映射 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 都是基于发布/订阅（Pub/Sub）模型的消息系统，两者概念上存在很多相似之处，下图列举了关键概念...
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。在使用...
什么是Terraform 基本功能 Terraform是IT基础架构自动化编排工具，可以用代码来管理维护IT资源。更多信息，请参见 什么是Terraform。Terraform的命令行接口CLI（Command Line Interface）提供一种简单机制，用于将配置文件部署到阿里云或...
每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 RocketMQ 版 服务，为什么会有扣费？如何关闭 云消息队列 ...
什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台，使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建，通过企业级功能扩展了Kafka的优势，同时消除了Kafka管理或...
消息在队列中的存储情况如下：消息存储管理粒度说明 云消息队列 RocketMQ 版 按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版 基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...
消费时间过慢，超过一定时间（max.poll.interval.ms 设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。消费者数量过多，为避免当前Topic-Partition的任务浪费，需要关闭一定数量的消费者，触发...
本文汇总了使用 云消息队列 Kafka 版 实例时的常见问题。计费问题 为什么购买了按量付费实例后不使用也要收费？为什么按流量峰值收费？按流量峰值收费的依据是什么？为什么额外增加分区要收费？我使用的Connector组件如何计费？客户端报错 ...
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
本文介绍 云消息队列 RocketMQ 版 中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
仅限有权限的RAM用户在 云消息队列 RocketMQ 版 的控制台上管理资源，以及通过SDK/API发布与订阅消息。应用场景 企业A购买了 云消息队列 RocketMQ 版 服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已开通函数计算服务，...
Control Center是 云消息队列 Confluent 版 的核心管理服务，提供了一个可视化的监控平台。本文介绍Control Center平台上的基本操作。登录Control Center 创建 云消息队列 Confluent 版 集群，详情请参见 购买和部署实例。在 云消息队列 ...
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
云消息队列 RabbitMQ 版 支持Spring框架的SDK，本文介绍如何集成Spring框架的SDK客户端收发消息。前提条件 您已在 云消息队列 RabbitMQ 版控制台 创建实例、Vhost、Exchange、Queue等相关资源，具体操作，请参见 步骤二：创建资源。安装...
什么是延时消息 延时消息是指在指定时间段之后才被消费者消费的消息。应用场景 延时消息适用于以下场景：对消息生产和消费有时间窗口要求的场景。例如，在电商交易中超时未支付关闭订单的场景，在订单创建时会发送一条延时消息。这条消息将...
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
什么是订阅关系 云消息队列 RocketMQ 版 里的一个Group ID代表一个Consumer实例群组。对于大多数分布式应用来说，一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版 的订阅关系主要由Topic+Tag共同组成，即一个Group ID下...
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
本文介绍 云消息队列 Kafka 版 的产品功能动态及对应的文档。2024-04-15 功能名称 功能描述 功能类型 相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服 云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...