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

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

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

迁移上云

云消息队列 Kafka 版提供全托管、免运维的迁移上云服务，用于自建实例或跨云云实例与云消息队列 Kafka 版实例之间的数据同步。本文介绍迁移上云的源实例类型、使用限制、跨VPC数据同步以及使用流程。前提条件您已购买并部署云消息队列...

消息发送重试和流控机制

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

作为Input接入

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

步骤三：调用SDK收发消息

云消息队列 RocketMQ 版提供多种语言的SDK用于收发不同类型的消息，本文以Java SDK为例，说明如何调用SDK连接云消息队列 RocketMQ 版服务端，完成普通消息的收发流程。前提条件步骤二：创建资源安装IDEA 您可以使用IntelliJ IDEA或者...

步骤二：创建资源

一个新的应用接入云消息队列 RabbitMQ 版服务端，您需要提前创建云消息队列 RabbitMQ 版的相关资源，包括创建云消息队列 RabbitMQ 版实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...

订阅者最佳实践

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

开通服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 MQTT 版资源，并使用SDK收发消息。前提条件您已注册阿里云账号并完成...

实例生命周期管理

本文介绍云消息队列 Kafka 版实例的控制台操作说明及生命周期管理过程，生命周期包括部署、释放、恢复实例等。控制台操作说明云消息队列 Kafka 版实例操作列的可操作性说明如下：操作不显示：不可操作。操作置灰：当前状态下不可操作...

创建前提

AliyunKafkaFullAccess：管理云消息队列 Kafka 版的权限。AliyunFCFullAccess：管理函数计算FC（Function Compute）的权限。AliyunEventBridgeFullAccess：管理事件总线EventBridge 的权限。目标服务的管理权限。除上述必要权限外，如...

使用云消息队列 Kafka 版时出现消息堆积

使用云消息队列 Kafka 版时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...

使用Canal将MySQL的数据同步至云消息队列 Kafka 版

您可以在云消息队列 Kafka 版控制台的 Topic 管理页面创建。具体操作，请参见步骤三：创建资源。canal.mq.dynamicTopic 否动态Topic规则表达式。设置Topic匹配规则表达式，可以将不同的数据表数据同步至不同的Topic。具体设置方法，...

CreateAccount

背景信息开源客户端访问云消息队列 RabbitMQ 版服务端时，需要传入用户名和密码进行权限认证，认证通过才允许访问服务端。云消息队列 RabbitMQ 版支持通过阿里云访问控制（RAM）的AccessKey和AccessKey Secret生成用户名和密码。注意事项 ...

自定义鉴权模式

过期设置：云消息队列 MQTT 版对于身份认证、资源授权以及连接黑名单等数据暂不提供过期设置功能，您可以及时删除相关接口进行管理。容量限制：无论是身份认证，还是资源权限都占用了实例的元数据存储，所以您需要自行管理鉴权数据，及时...

OnsMessageDetail-查询消息详细信息

接口说明注意阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。调试您可以在OpenAPI Explorer中直接...

快速使用MQTT.fx模拟SDK收发消息

权限策略名称说明 AliyunMQFullAccess 管理云消息队列 MQTT 版的权限，等同于阿里云账号的权限，被授予该权限的RAM用户具有所有消息收发权限且有控制台所有功能操作权限。AliyunMQPubOnlyAccess 云消息队列 MQTT 版的发布权限，被授予...

集成概述

主要能力是将各类数据流入至云消息队列 Kafka 版，并且可靠地管理来自不同源头的数据源，同时对来源数据进行筛选和过滤。概念介绍—消息流出（Sink）消息流出的主要能力是将云消息队列 Kafka 版的数据流出到各类数据目标，Connector生态...

MNS回调事件通知

视频点播支持通过控制台或API/SDK的方式配置事件通知，具体配置方法如下：控制台方式登录视频点播控制台，在左侧导航栏选择配置管理>媒体处理配置>回调设置，进入回调设置页面，配置回调的区域及队列并勾选需要回调的事件。详细操作请...

HTTP SDK错误码列表

The receipt handle you provided has expired.404 消费消息过慢导致消息重新回到队列生成新的 ReceiptHandle，之前的 ReceiptHandle 失效。ReceiptHandleError The receipt handle you provide is not valid.400 请求参数不合法。详细信息...

消费重试

消费者出现异常，云消息队列 RocketMQ 版会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景云消息队列 RocketMQ 版的消费重试主要解决的是业务处理逻辑失败导致的...

RAM鉴权

微消息队列MQTT版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKeyId和AccessKeySecret），按需为用户分配最小权限。在使用RAM账号...

开通消息队列服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 RocketMQ 版资源，并使用资源通过SDK收发消息。前提条件您已注册...

开通消息队列服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 RocketMQ 版资源，并使用资源通过SDK收发消息。前提条件您已注册...

步骤一：（可选）RAM用户授权

RAM用户默认没有云消息队列 RabbitMQ 版资源的操作权限。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能拥有云消息队列 RabbitMQ 版资源的操作权限和消息收发权限。背景信息本操作仅针对RAM用户，若您的账号为阿里云账号，则...

基本概念

本文主要对云消息队列 RocketMQ 版涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用云消息队列 RocketMQ 版。Topic 消息主题，一级消息类型，通过Topic对消息进行分类。更多信息，请参见 Topic与Tag最佳实践。消息...

消息收发流程变更

云消息队列 MQTT 版 V2.x.x版本强依赖云消息队列 RocketMQ 版作为消息存储，因此云消息队列 MQTT 版消息和云消息队列 RocketMQ 版天然打通，创建了Topic后即可天然使用云消息队列 RocketMQ 版和云消息队列 MQTT 版的SDK相互通信...

权限策略

云消息队列 MQTT 版权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍云...

Control Center基本使用

Control Center是云消息队列 Confluent 版的核心管理服务，提供了一个可视化的监控平台。本文介绍Control Center平台上的基本操作。登录Control Center 创建云消息队列 Confluent 版集群，详情请参见购买和部署实例。在云消息队列 ...

OnsDLQMessageResendById-重发指定的死信消息

当前消息队列 RocketMQ 版不管理死信重发的状态，重发后消费成功的消息不会从死信队列中移除。需自行管理、判断消息是否需要重发。避免多次无意义地重发，从而造成重复消费。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算...

Topic使用变更

变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了自身的消息存储，因此所有的云消息队列 MQTT 版 Topic资源都需要在云消息队列 MQTT 版控制台或调用其OpenAPI进行管理。云消息队列 MQTT 版的Topic资源不再和云消息队列 RocketMQ ...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

订阅消息

Pull：消息由Consumer主动从云消息队列 RocketMQ 版拉取。Pull Consumer提供了更多接收消息的选择。相比于Push Consumer，您可以使用Pull Consumer更加自由地控制消息拉取。具体的接口信息请参见接口和参数说明。重要如需使用Pull ...

RAM鉴权

云消息队列 MQTT 版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。在使用...

权限策略

云消息队列 MQTT 版权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍云...

功能特性

Kafka商业模式功能集功能功能描述参考文档 Serverless版本升降配管理在云消息队列 Kafka 版控制台完成实例升配或降配，配置项包括规格类型、实例类型、发送能力预留和订阅能力预留等。升级实例配置降低实例配置弹性策略 V3系列...

操作指南

您可以在云消息队列 RocketMQ 版控制台管理实例、Topic、Group等资源，并进行消息轨迹查询、创建云监控等运维操作。云消息队列 RocketMQ 版5.x系列资源管理迁移上云版本管理消息轨迹监控报警其他更多操作，请参见 5.x系列操作指南...

Dashboard

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RabbitMQ 版为企业版和铂金版实例提供Dashboard大盘功能。通过该功能，您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据，帮助您及时...

证书管理概述

云消息队列 MQTT 版支持基于X.509证书的双向认证，分别通过服务器证书和设备证书完成服务端和客户端的认证，本文介绍如何在云消息队列 MQTT 版控制台管理证书。注意事项仅铂金版、专业版实例支持双向认证能力，基础版和Serverless版...

配置消息日志

您可以使用云消息队列 RabbitMQ 版的日志管理功能将云消息队列 RabbitMQ 版实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件创建云消息队列...

欠费说明

若您在停服后7天内未完成续费，阿里云将主动释放您在云消息队列 MQTT 版上创建的实例，并且删除您实例下创建的Topic与Group ID，被释放的实例以及资源均不可恢复。按量付费实例欠费说明重要云消息队列 MQTT 版已不再售卖按量付费实例...

主动队列管理算法怎么玩

新品推荐