主动队列管理算法怎么重启-主动队列管理算法怎么重启文档介绍内容-阿里云

管理资源队列

在左侧导航栏，单击 队列管理。单击添加队列。填写队列名称和资源量。配置说明队列名称队列名称不可重复，只允许小写字母、数字和中划线（-）且长度不超过32位。说明资源队列添加成功后，不可修改资源队列名称。资源量（CU）允许...

YARN调度器

主要特性 CapacityScheduler具备如下的特性：多级队列（树形结构）：支持多级租户管理，父队列资源配额能够限制其下所有子队列的资源使用，单个子队列的资源配额也不能超过父队列的资源配额，因此对于多租户管理具备较高的可控性，能够满足...

使用异常

无法连接 Broker 客户端启动失败，出现“Can not find name server with endpoint”报错启动 Producer、Consumer 失败，Group ID 重复主动订阅消息，获取队列列表失败消息显示 Consumed,但消费端未感知到无法连接 Broker 可能的原因：...

服务器证书管理

步骤三：使用服务器证书启动服务启动服务会重启云消息队列 MQTT 版实例，重启时间预计5～10分钟，重启后客户端即可使用服务器证书做服务端认证。启动服务后，8883端口将开启双向认证，同时关闭单向认证。警告使用服务器证书启动服务，...

基本概念

本文说明云消息队列 Kafka 版涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...

生产者（Producer）

本文介绍云消息队列 RocketMQ 版中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义生产者是云消息队列 RocketMQ 版系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...

步骤三：创建资源

当使用云消息队列 Kafka 版进行消息收发时，您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从云消息队列 Kafka 版消费消息。背景信息在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

订阅者最佳实践

本文主要介绍云消息队列 Kafka 版订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程云消息队列 Kafka 版订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡每个 ...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。更多信息，请参见 VPC...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

消息发送重试和流控机制

触发条件云消息队列 RocketMQ 版的消息流控触发条件如下：存储压力大：参考消费进度管理的原理机制，消费者分组的初始消费位点为当前队列的最大消费位点。若某些场景例如业务上新等需要回溯到指定时刻前开始消费，此时队列的存储压力会...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从云消息队列 Kafka 版消费消息。背景信息在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

将云消息队列 Kafka 版接入阿里云Elasticsearch

随着时间的积累，云消息队列 Kafka 版中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将云消息队列 Kafka 版中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

如何快速测试云消息队列 Kafka 版服务端是否正常？

在创建并部署云消息队列 Kafka 版实例后，您可以使用云消息队列 Kafka 版控制台直接发送消息，快速测试服务端是否正常。前提条件您已创建并部署云消息队列 Kafka 版实例，且实例处于服务中状态。操作流程快速测试云消息队列 ...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

MQTT客户端上下线事件数据流出

您可通过配置云消息队列 MQTT 版的客户端上下线通知规则，将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及云消息队列 MQTT 版与其他阿里云...

证书管理概述

服务器证书需要您自行购买或自行签发后，托管到数字证书管理服务，并通过服务器证书重启云消息队列 MQTT 版服务。具体操作，请参见服务器证书管理。服务端认证客户端云消息队列 MQTT 版服务端对客户端的认证通过对设备证书的认证完成...

客户端证书认证

服务器证书需要您自行购买或自行签发后，托管到数字证书管理服务，并通过服务器证书重启云消息队列 MQTT 版服务。具体操作，请参见服务器证书管理。服务端认证客户端云消息队列 MQTT 版服务端对客户端的认证通过对设备证书的认证完成...

消息存储和清理机制

消息在队列中的存储情况如下：消息存储管理粒度说明云消息队列 RocketMQ 版按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...

管理队列

本文介绍如何使用队列分组管理计算节点，包括创建和删除队列，以及在队列之间移动节点。背景信息创建集群时会自动创建一个默认队列，计算节点默认会加入到该队列中。操作步骤打开节点与队列页面。登录弹性高性能计算控制台。在顶部...

编辑资源队列

资源队列用于管理和调度集群资源，旨在实现资源的灵活分配和优化。通过阿里云EMR控制台，您可以方便地管理资源队列，并关联不同的分区。前提条件已创建集群，且集群状态为运行中。创建集群详情，请参见创建集群。使用限制 YARN调度器需...

数据加密

云消息队列 RabbitMQ 版存储加密默认采用行业标准的AES-256加密算法，利用密钥管理服务KMS（Key Management Service）加密您的数据信息，该项能力完全免费。传输加密使用限制传输加密仅Serverless版、企业版、铂金版实例支持，专业版...

云消息队列 RocketMQ 版4.x系统权限策略参考

本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...

云消息队列 RabbitMQ 版系统权限策略参考

本文描述云消息队列 RabbitMQ 版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制...

消息队列Kafka版系统权限策略参考

本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）...

查看Rebalance详情

消费时间过慢，超过一定时间（max.poll.interval.ms 设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。消费者数量过多，为避免当前Topic-Partition的任务浪费，需要关闭一定数量的消费者，触发...

SDK概述

云消息队列 Kafka 版使用SCRAM-SHA-256加密算法实现身份校验，比PLAIN机制安全性更高，同样支持不重启实例的情况下动态增加SASL用户。关于接入点的详细信息，请参见接入点对比。Demo使用说明根据购买的实例信息选择Demo文件，通过配置后...

新功能发布记录

本文介绍云消息队列 Kafka 版的产品功能动态及对应的文档。2024-04-15 功能名称功能描述功能类型相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...

查看任务执行记录

在某个实例下发起重启类任务（包括配置变更、版本升级、开启ACL、实例升配）后，您可以在云消息队列 Kafka 版控制台查看重启类任务的执行记录，帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件创建并部署云消息队列 Kafka 版 ...

接入点对比

云消息队列 Kafka 版使用SCRAM-SHA-256加密算法实现身份校验，比PLAIN机制安全性更高，同样支持不重启实例的情况下动态增加SASL用户。SSL（Secure Sockets Layer）：用以保障数据传输过程的安全，采用数据加密技术，防止数据在网络传输...

查看实例风险

消费流量 Group与Topic的订阅关系服务端小版本升级消费位点提交频率存在Rebalance的Group 消费客户端主动离开队列使用Sarama Go客户端操作步骤登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。...

配额与限制

云消息队列 RocketMQ 版对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用云消息队列 RocketMQ 版时不要超过对应的限制值，避免应用出现异常。参数限制以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...

SSL证书算法升级说明

重要仅在云消息队列 Kafka 版的实例配置信息页面修改SSL证书算法位数，将会导致客户端无法使用，升级前请按照操作步骤下载新版证书，修改客户端证书配置后重启。若您的实例为V3系列Serverless实例，当开启公网时，使用的SSL证书算法位数...

开发参考

OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版管理资源的主要方式之一。API参考汇总了云消息队列 RocketMQ 版所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...

计费FAQ

虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与云消息队列 RabbitMQ 版保持连接，即代码逻辑层面还在主动发起连接到云消息队列 RabbitMQ 版的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...

计费FAQ

虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与云消息队列 RabbitMQ 版保持连接，即代码逻辑层面还在主动发起连接到云消息队列 RabbitMQ 版的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...

主动队列管理算法怎么重启

新品推荐