本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务,将 云消息队列 RabbitMQ 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建消息流出任务 登录 云...
如需查看 云消息队列 RocketMQ 版 的服务可用性等级指标及赔偿方案,请参见 云消息队列 RocketMQ 版服务等级协议。
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务,将 云消息队列 RocketMQ 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...
概述 本文主要介绍客户端首次接入云消息队列 Kafka 版时,出现异常的排查方法。详细信息 客户端首次接入云消息队列 Kafka 版时如果出现异常,您可以通过以下三个方面进行排查:网络连通问题:通常有如下几种情况可能会导致网络不通,客户端...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务,实现将其他数据源中的数据快速导入 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务,实现将其他数据源中的数据快速导入 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务,以实现将 云消息队列 RocketMQ 版 指定实例的数据流出至另外的 云消息队列 RocketMQ 版 实例中。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态...
本文介绍 云消息队列 Confluent 版 的定义。什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台,使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建,通过企业级...
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台,面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
本文为您介绍目标数据库实例为 专线/VPN网关/智能网关 方式接入的 阿里云消息队列Kafka版 时,部分特殊参数的配置方法和获取方式。注意事项 使用此方案将 阿里云消息队列Kafka版 接入DTS,会将数据写入到您指定的节点中。若您的源库为MySQL...
问题描述 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...
不支持。与开源RabbitMQ的单机部署天然支持顺序消息不同,阿里云 云消息队列 RabbitMQ 版 为自研产品,分布式部署,暂不支持顺序消息。
本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述,供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合,可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
本文描述云消息队列 RabbitMQ 版支持的所有系统权限策略及其对应的权限描述,供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合,可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制...
本文提供使用 消息队列RocketMQ版 的TCP Java SDK收发消息的快速入门视频。
物联网络管理平台支持数据出口至阿里云中间件消息队列MQ,本文介绍如何在物联网络管理平台上配置数据流转至消息队列MQ。配置出口数据 登录 物联网络管理平台控制台。在左侧导航栏选择 节点管理>节点分组,单击一条节点分组对应 操作 栏下的...
如果当前产品下设备与物联网平台之间的上下行消息量大于1,000 QPS,需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费(例如过滤、分析、存储等),可以使用云产品流转功能将物联网平台数据转发到消息队列(RocketMQ)...
通过数据传输服务DTS(Data Transmission Service),您可以将自建MySQL同步至 云消息队列 Kafka 版,扩展消息处理能力。前提条件 您已完成以下操作:自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述,供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合,可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制(RAM)...
概述 不在同一可用区内的ECS实例可通过非公网的方式访问云消息队列 Kafka 版实例,详情请查看以下内容。详细信息 以非公网的方式访问云消息队列 Kafka 版实例时,必须满足以下两个条件:ECS实例与云消息队列 Kafka 版实例在同一VPC网络实例...
如果当前产品下设备与物联网平台之间的上下行消息量大于1,000 QPS,需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费(例如过滤、分析、存储等),可以使用云产品流转功能将物联网平台数据转发到消息队列(RocketMQ)...
本文描述云消息队列 RocketMQ 版5.x支持的所有系统权限策略及其对应的权限描述,供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合,可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 作为事件流中的服务类型。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建...
本文为您介绍本地IDC如何通过物理专线访问云上消息队列RocketMQ版,实现本地IDC使用消息队列RocketMQ版收发并处理消息。背景信息 本文以下图场景为例,某企业在阿里云华北2(北京)地域部署了专有网络VPC(Virtual Private Cloud)和交换机...
问题描述 使用阿里云消息队列Kafka版时,删除Group后,仍然收到消息堆积的告警信息,如何过滤某个Group的消费堆积告警。问题原因 发生消息堆积告警信息的原因如下:2.2.0以前的Kafka服务端版本,开源Kafka未提供删除Group和消费位点的Open...
消息队列 RocketMQ 是一种常用的异步 RPC 技术。本文以阿里云消息队列 RocketMQ 为例,介绍了如何使用 ACM 对消息队列 RocketMQ 实现流量控制。迁移到MSE Nacos ACM进入下线状态,所有配置管理相关的需求由MSE中的Nacos承接(ACM独享版,更...
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时,为避免因磁盘容量不足而导致机器宕机,进而影响服务可用性,云消息队列 Kafka 版 会根据磁盘使用率的多少,执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
随着时间的积累,云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将...
使用 云消息队列 Kafka 版 时,可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况,以及处理方法。客户端消费流程 了解客户端消费流程,有助于理解消息是否堆积。一般情况下,客户端消费流程大致如下:判断消息...
消息队列RocketMQ 5.0已与操作审计服务集成,您可以在操作审计中查询用户操作消息队列RocketMQ 5.0产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中,满足实时审计、问题回溯分析等需求。操作...
在创建并部署 云消息队列 Kafka 版 实例后,您可以使用 云消息队列 Kafka 版 控制台直接发送消息,快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中,自定义权限策略是指在系统权限策略之外,您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
云消息队列 Kafka 版 已与操作审计服务集成,您可以在操作审计中查询操作 云消息队列 Kafka 版 产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中,满足实时审计、问题回溯分析等需求。事件...
本文介绍 消息服务MNS 如何保证多个消费者访问同一消息队列,不会丢失消息或者重复消费消息的问题。消息服务MNS 中每个队列都具有可配置的不可见时间段属性(即队列的取出消息隐藏时长属性)。当队列中的某条消息被取出后,在不可见时间段...
消息队列RocketMQ版已与操作审计服务集成,您可以在操作审计中查询用户操作消息队列RocketMQ版产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中,满足实时审计、问题回溯分析等需求。操作审计...
云消息队列 RocketMQ 版 所提供的TCP Java SDK支持多线程消费,且适用于所有消息类型,本文介绍如何设置消费线程数的方法。在启动Consumer时,设置一个ConsumeThreadNums属性即可。具体示例如下所示。public static void main(String[]args...
本文介绍 云消息队列 Kafka 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中,自定义权限策略是指在系统权限策略之外,您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来...
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中,自定义权限策略是指在系统权限策略之外,您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
本文为您介绍 云消息队列 RocketMQ 版 连接器。重要 鉴于 云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制,使用该版作为实时计算Flink版对接的消息中间件,可能会导致Flink作业运行不稳定。因此,在选择消息中间件...