云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 指定实例的数据流出至另外的 云消息队列 RocketMQ 版 实例中。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态...
云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将其他数据源中的数据快速导入 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。创建...
云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 RocketMQ 版 指定实例的数据流入至另外的 云消息队列 RocketMQ 版 实例。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。...
云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 指定实例的数据导入至另外的 云消息队列 RocketMQ 版 实例。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。...
自建RocketMQ集群迁移上云
和开源Apache RocketMQ相比，阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验，本文为您介绍开源RocketMQ集群迁移上云的方案...
云消息队列 RocketMQ 版服务等级协议
如需查看 云消息队列 RocketMQ 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 RocketMQ 版服务等级协议。
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。前置概念 阅读...
云消息队列 RocketMQ 版自定义权限策略
["rocketmq:GetAnalyticsQuery","rocketmq:SubmitAnalyticsQuery","rocketmq:ListAnalyticsQuery"],"Resource":["acs:rocketmq:*:{#accountId}:*/*"]}]} 授权信息参考 使用自定义权限策略，您需要了解业务的权限管控需求，并了解 云消息...
RocketMQ全链路追踪解决方案
链路追踪功能可在多个服务进行交互时记录请求在系统的传输过程，并提供详细的日志和性能数据，云消息队列 RocketMQ 版 支持将符合OpenTelemetry标准的Trace数据集成至阿里云的链路追踪服务中，帮助您快速诊断异常问题。Trace定义 云消息...
云消息队列 RocketMQ 版升级影响说明
为了提升您的使用体验并持续提供更优质的服务，云消息队列 RocketMQ 版 服务端版本需不断进行升级与优化。在升级期间可能会对服务产生一定影响，本文将为您介绍可能出现的问题及其应对措施。升级期间可能会出现下列情况：云消息队列 ...
云消息队列 RocketMQ 版升级影响说明
为了提升您的使用体验并持续提供更优质的服务，云消息队列 RocketMQ 版 服务端版本需不断进行升级与优化。在升级期间可能会对服务产生一定影响，本文将为您介绍可能出现的问题及其应对措施。升级期间可能会出现下列情况：云消息队列 ...
RocketMQ 5.x Serverless实例概述
云消息队列 RocketMQ 版 5.x的Serverless实例能够根据业务负载快速伸缩资源，支持根据实际的使用量分配资源和计算费用，能够有效的节约成本。本文为您介绍Serverless版实例的工作原理、产品优势和使用场景。背景信息 消息中间件是现代企业...
云消息队列 RocketMQ 版自定义权限策略
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
云消息队列 RocketMQ 版5.x系统权限策略参考
本文描述云消息队列 RocketMQ 版5.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
云消息队列 RocketMQ 版4.x系统权限策略参考
本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
消息队列RocketMQ版客户端如何设置消费线程数？
云消息队列 RocketMQ 版 所提供的TCP Java SDK支持多线程消费，且适用于所有消息类型，本文介绍如何设置消费线程数的方法。在启动Consumer时，设置一个ConsumeThreadNums属性即可。具体示例如下所示。public static void main(String[]args...
如何快速使用消息队列RocketMQ版的TCP Java SDK收发...
本文提供使用 云消息队列 RocketMQ 版 的TCP Java SDK收发消息的快速入门视频。
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
RocketMQ
名称 类型 描述 示例值 object RocketMQ 消息通知参数。TopicName string RocketMQ Topic 名称。如果需使用 RocketMQ 做消息通知，该参数必填。topic1 InstanceId string RocketMQ 实例 Id。如果需使用 RocketMQ 做消息通知，该参数必填。...
RocketMQ触发器
消息队列 RocketMQ 版 作为事件源通过 事件总线EventBridge 与 函数计算 集成后，通过 消息队列 RocketMQ 版 触发器（以下简称RocketMQ触发器）能够触发关联函数执行，通过函数可以对发布到 消息队列 RocketMQ 版 中的消息进行自定义处理。...
RocketMQ触发器
消息队列RocketMQ版 作为事件源通过 事件总线EventBridge 与 函数计算 集成后，通过 消息队列RocketMQ版 触发器（以下简称RocketMQ触发器）能够触发关联函数执行，通过函数可以对发布到 消息队列RocketMQ版 中的消息进行自定义处理。...
RocketMQ接入
可观测监控 Prometheus 版 可通过配置接入参数主动拉取消息队列RocketMQ的性能指标，实现对其运行状况的实时监控和数据分析。前提条件 容器服务环境 已开通可观测监控Prometheus版。具体操作，请参见 计费说明。已创建Kubernetes集群。具体...
RocketMQ接入
可观测监控 Prometheus 版 可通过配置接入参数主动拉取消息队列RocketMQ的性能指标，实现对其运行状况的实时监控和数据分析。前提条件 容器服务环境 已开通可观测监控Prometheus版。具体操作，请参见 计费说明。已创建Kubernetes集群。具体...
新建 RocketMQ 数据源
VPC 内自建 RocketMQ 实例对于网络的处理：安装 RocketMQ 实例的 ECS 的安全组需要添加对应 VPC 的网段，放开 RocketMQ 实例的 namesvr 和 broker 的所有端口。操作步骤 登录 OceanBase 管理控制台。在左侧导航栏，单击 数据传输 数据源...
Spark对接RocketMQ
本文介绍如何通过Spark Streaming消费消息队列RocketMQ（简称MQ）中的数据并计算每个Batch中的单词。通过Spark访问MQ 代码示例如下。val Array(cId,topic,subExpression,parallelism,interval)=args val accessKeyId=System.getenv(...
创建RocketMQ数据源
通过创建RocketMQ数据源能够实现Dataphin读取RocketMQ的业务数据或向RocketMQ写入数据。本文为您介绍如何创建RocketMQ数据源。背景信息 RocketMQ即阿里云消息队列RocketMQ版，是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可靠的...
alicloud_rocketmq_topic
rocketmq_topic" "default" { remark = "example" instance_id = alicloud_rocketmq_instance.createInstance.id message_type = "NORMAL" topic_name = var.name } Argument Reference The following arguments are supported: instance_id -(Required,ForceNew)...
创建RocketMQ数据源
通过创建RocketMQ数据源能够实现Dataphin读取RocketMQ的业务数据或向RocketMQ写入数据。本文为您介绍如何创建RocketMQ数据源。背景信息 RocketMQ即阿里云消息队列RocketMQ版，是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高...
云消息队列 RocketMQ 版
本文为您介绍 云消息队列 RocketMQ 版 连接器。重要 鉴于 云消息队列 RocketMQ 版 4.x标准版实例共享API调用弹性上限为每秒5000次，使用该版本的消息中间件在与实时计算Flink版对接时，若超过上限会触发限流机制，可能会导致Flink作业运行...
添加RocketMQ数据源
本文介绍如何添加RocketMQ数据源。数据源添加 首先进入LTS操作页面，数据源管理-RocketMQ数据源 录入MQ的相关信息，点击创建，创建对应的MQ数据源。参数说明 获取NameSrvAddr NameSrvAddr表示MQ的接入点，对于自建客户，请自行查询MQ的配置...
- 产品推荐
- 这些文档可能帮助您