集群消费和广播消费是云消息队列RocketMQ版的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个...
配置指定Group ID对应的消费集群的消息读取权限。本接口一般用于禁止特定Group ID读取消息的场景。接口说明注意阿里云提供的OpenAPI属于管控类API，用于管理和查询阿里...
在使用自建Kafka集群时，当您希望业务的成本更低、弹性更强、可靠性更高时，您可以将自建Kafka集群迁移上至云消息队列Kafka版，云消息队列Kafka版提供全托管、免...
您可以将开源RocketMQ集群迁移到云消息队列RocketMQ版上以获得更好的业务体验，本文为您介绍开源RocketMQ集群迁移上云的方案及原理。产品差异对比和开源RocketMQ...
本文介绍如何使用MirrorMaker将自建Kafka集群的数据迁移到云消息队列Kafka版集群。前提条件您已完成以下操作：下载迁移工具MirrorMaker迁移Topic上云背景信息Kafka的...
数据迁移使用ClusterLink做数据迁移，由阿里云技术支持提供远程协助，适用于数据重要，消息保留时间长、需要将数据迁移到新的集群上的场景。迁移前需注意什么？在迁移...
对于云消息队列Confluent版集群来说，影响资源使用的因素众多，包括使用的业务场景、业务应用程序性能等，本文结合一般场景给出云消息队列Confluent版集群资源评估参考...
本文介绍如何进行云消息队列Confluent版集群的网络访问与安全设置。网络访问类型云消息队列Confluent版集群提供阿里云VPC访问和公网访问方式。阿里云VPC访问VPC访问...
本文说明如何查看自建Kafka集群迁移到云消息队列Kafka版的进度。前提条件您已开始自建Kafka集群迁移上云。迁移类型包括：通过命令行迁移迁移Topic上云迁移Group上云...
您可以将自建Kafka集群元数据导出，然后导入云消息队列Kafka版实例，云消息队列Kafka版会解析成功导入的元数据，并支持在创建任务时可视化配置Topic和Group，配置...
本文介绍如何使用云消息队列Kafka版提供的迁移工具将自建Kafka集群的Topic迁移到云消息队列Kafka版实例。前提条件您已完成以下操作：下载JDK 8下载迁移工具kafka-...
信息云消息队列Kafka版控制台提供迁移实例功能，您可以使用该功能将自建Kafka集群或其他云Kafka集群的元数据（Topic和Group配置信息）和消息数据同步到目标集群，...
执行以下命令，在Source集群上创建一个具有单分区的待镜像的Topic，以便更容易观察复制消息的顺序。kafka-topics-create-topic test-topic-partitions 1\-bootstrap-server source-...
如果需要通过公网接入云消息队列Confluent版，您可以为集群开启公网。开启公网登录云消息队列Confluent版控制台，在左侧导航栏，单击实例列表。在顶部菜单栏，选择地域，在...
本文描述了如何启动两个Apache Kafka集群，然后启动一个Replicator进程在它们之间复制数据。背景信息自Confluent Platform 7.5起，ZooKeeper已不再用于新部署。Confluent建议...
如需使用客户端连接云消息队列Kafka版收发消息，您需要根据客户端的网络环境类型及传输的安全需要来配置接入点。默认接入点适用于在保密性较高的VPC环境收发消息；...
本文介绍如何使用云消息队列Kafka版提供的迁移工具将自建Kafka集群的Group迁移到云消息队列Kafka版实例。前提条件您已完成以下操作：下载JDK 8下载迁移工具kafka-...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将PolarDB MySQL版集群同步至阿里云消息队列Kafka版，扩展消息处理能力。前提条件已创建源PolarDB MySQL版集群，...
当消费端设置过滤条件时，可实现仅消费源或目标集群消息。该Key在消息同步时，会注入到消息自定义属性UserProperty中。请避免与业务需要的属性相冲突。源集群Value：...
步骤四：更换接入点确认此次迁移范围内的所有生产者以及消费者，将源集群消息收发代码中的接入点修改为目标阿里云云消息队列RocketMQ版实例的接入点。步骤五：迁移消息...
业务流量指业务上实际消息产生的流量，集群内副本复制流量指的是云消息队列Kafka版集群3备份时产生的复制流量。业务流量为双通道。高写版读写比1:1，高读版读写...
碎片化存储否是Compact不支持支持幂等不支持支持事务不支持支持消息类型普通消息集群重启或者宕机时，会导致极少量乱序。分区顺序消息集群宕机时，会自动从ISR中...
业务流量指业务上实际消息产生的流量，集群内副本复制流量指的是云消息队列Kafka版集群3备份时产生的复制流量。订阅能力预留订阅能力预留规格为20～17100 MB/s。...
业务流量指业务上实际消息产生的流量，集群内副本复制流量指的是云消息队列Kafka版集群3备份时产生的复制流量。业务流量为双通道。高写版读写比1:1，高读版读写...
挑战在大规模分布式应用中，曾经的单体应用按横向和纵向的维度被拆分到集群的各个节点之中，为了解决服务及数据调用的问题，引入了分布式服务框架、分布式消息集群、...
集群级别的高可用，是云消息队列RocketMQ版跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者...
本文介绍SOFAStack消息队列的集群消费和广播消费的基本概念、适用场景以及注意事项。消息队列是基于发布/订阅模型的消息系统。消费者，即消息的订阅方订阅关注的Topic，...
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至云消息...
当Kafka集群出现消息堆积、磁盘水位过高等异常情况时，可查看分区状态了解服务端的消息量及各个分区的消费进度，定位异常原因。前提条件已创建Topic操作步骤登录云...
集群级别的高可用，是消息队列跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为...
背景信息IMB（Intel MPI Benchmarks）用于评估HPC集群在不同消息粒度下节点间点对点、全局通信的效率。MPI（Message Passing Interface）是支持多编程语言编程的并行计算通信库...
通过数据传输服务DTS（Data Transmission Service），您可以将RDS MySQL或RDS MySQL Serverless的数据库同步至自建Kafka集群，扩展消息处理能力。前提条件Kafka集群的版本为...
ConsoleGroupConsumerUpdate配置指定Group ID对应的消费集群的消息读取权限。ConsoleGroupCreate创建客户端Group ID。ConsoleGroupDelete删除Group ID。ConsoleGroupList获取Group ID...
高吞吐能力：在海量消息堆积的情况下，始终能保持云消息队列Confluent版集群的高吞吐能力。全自动巡检运维体系保障，服务可用性专业版实例达到99.9%、企业版实例达到99.95%...
OnsGroupConsumerUpdate配置消费集群的消息读取权限配置指定Group ID对应的消费集群的消息读取权限。本接口一般用于禁止特定Group ID读取消息的场景。OnsGroupList获取...
前提条件您可以根据需求选择以下任意一种方式连接集群：连接阿里云云消息队列Kafka版集群云消息队列Kafka版集群已创建。详情请参见创建资源。Flink工作空间与Kafka...