监控安全风险 DMS for RabbitMQ提供基于云监控服务CES的资源和操作监控能力，帮助用户对每个RabbitMQ实例进行自动实时监控、告警和通知操作。用户可以实时掌握实例的各类业务请求、资源占用、流量、连接数和消息积压等关键信息。 关于DMS for RabbitMQ支

查看更多 →

String 消息引擎的类型。 表2 Query参数 参数 是否必选 参数类型 描述 product_id 否 String 产品ID。 请求参数 无 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 engine String 分布式消息服务的产品类型。 versions

查看更多 →

数据保护技术 DMS for RocketMQ通过多种数据保护手段和特性，保障DMS for RocketMQ的数据安全可靠。 表1 DMS for RocketMQ的数据保护手段和特性 数据保护手段 简要说明 详细介绍 容灾和多活 根据对数据与服务的不同可靠性要求，您可以选择在

查看更多 →

如何在控制台查看重平衡日志。 重平衡日志存储在云日志服务（Log Tank Service，简称LTS）中，由LTS提供查询功能。 单机版实例不支持查看重平衡日志。 什么是Rebalance？ Rebalance是重新分配消息组中的消费者和Topic分区之间订阅关系的过程。在Re

查看更多 →

功能总览 全部 开通服务 申请套餐包 业务调用 查看服务监控 API接口 开通服务 开通可信分布式身份服务。 支持区域： 华北-北京四 开通服务 申请套餐包 服务开通完成后，支持申请1次免费套餐包，即可注册基于 区块链 的分布式身份，该套餐内包含2000次调用。 支持区域： 华北-北京四 申请套餐包

查看更多 →

manualAckCount ack消息数 ack消息数 - INT SUM rejectCount reject消息数 reject消息数 - INT SUM requeueCount requeue消息数 requeue消息数 - INT SUM lastError 错误信息 消费消息发生错误产生的错误信息

查看更多 →

占Kafka实例。 创建Kafka Topic 创建用于存储消息的Topic，供生产者生产消息以及消费者订阅消息。 连接实例 客户端使用内网/公网通过命令行连接Kafka实例，并生产消费消息。 管理消息 在控制台查看消息。

查看更多 →

Q实例。 创建RocketMQ Topic 创建用于存储消息的Topic，供生产者生产消息以及消费者订阅消息。 连接实例 客户端使用内网/公网通过命令行连接RocketMQ实例，并生产消费消息。 管理消息 在控制台查看消息。

查看更多 →

查询服务 服务分布： 表1 服务分布 服务名 服务器 安装目录 端口 data-ad-hoc 10.190.x.x 10.190.x.x /app/dt/data-ad-hoc 8086 安装查询服务 修改配置文件application-dev.yml 修改stdms.callback

查看更多 →

String 消息引擎。 engine_version String 消息引擎版本。 specification String 实例规格。 RabbitMQ实例单机返回vm规格。 RabbitMQ实例集群返回vm规格和节点数。 storage_space Integer 消息存储空间，单位：GB。

查看更多 →

到Kafka。 openGauss（ MRS 3.3.0及之后版本支持） ThirdKafka（DMS/DRS）->Hudi 该任务支持openGauss通过ThirdKafka（DMS/DRS）同步数据到Hudi。 Hudi 该任务支持从openGauss同步数据到Hudi。 Kafka

查看更多 →

Kafka队列打开公网SSL加密访问 配置变更 dms.kafkas DMS Kafka队列开启公网访问 配置变更 dms.kafkas 分布式消息服务RabbitMQ版 DMS RabbitMq队列打开SSL加密访问 配置变更 dms.rabbitmqs 分布式消息服务RocketMQ版 DMS Reliability队列打开SSL加密访问

查看更多 →

D CS （Distributed Cache Service）分布式缓存服务 huaweicloud_dcs_instance 包周期和按需 DMS KAFKA （Distributed Message Service） 分布式消息服务 huaweicloud_dms_kafka_instance 按需

查看更多 →

大小的数据。 日志转储至DIS 数据接入服务（Data Ingestion Service,简称DIS）提供日志长期存储能力和丰富的大数据分析能力。 日志转储至DMS DMS通过分布式消息服务API处理日志。 日志转储至DWS 数据仓库 服务（Data Warehouse Serv

查看更多 →

kafka.ssl.trust-store-password为服务器证书密码，无需修改，配置此密码是为了访问Java生成的jks文件。 spring.kafka.ssl.trust-store-password=dms@kafka ## spring.kafka.properties

查看更多 →

total监控（total，以客户端为维度统计消息推送详情） errorCount 错误次数 推送消息的错误次数 - INT SUM invokeCount invokeCount Publish调用次数 - INT SUM publishedMsgCount publishedMsgCount 推送消息数 - INT

查看更多 →

无 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 engine String 消息引擎类型。 versions Array of strings 消息引擎支持的版本。 products Array of RocketMQExtendProductInfoEntity

查看更多 →

生产者向RabbitMQ实例发送消息时，不会直接将消息发送到Queue，而是先将消息发送到Exchange中，Exchange根据路由键将消息发送到对应的Queue。 创建Queue Queue用于存储消息，每个消息都会被发送到一个或多个Queue中。 绑定Queue Exchange收到消息后，根据路由键将消息发送到绑定的Queue。

查看更多 →

数据保护技术 DMS for Kafka通过多种数据保护手段和特性，保障DMS for Kafka的数据安全可靠。 表1 DMS for Kafka的数据保护手段和特性 数据保护手段 简要说明 详细介绍 容灾和多活 根据对数据与服务的不同可靠性要求，您可以选择在单可用区内（单机房

查看更多 →

- 委托类型 选择“云服务”。 云服务 云服务 请选择“应用运维管理 AOM”。 - 持续时间 选择“永久”。 永久 描述 可选参数，用于补充说明该委托代理的详细信息。 - 在“权限选择”区域，单击“配置权限”。 配置以下权限： DMS User（或DMS UserAccess）

查看更多 →

脚本执行服务 服务分布： 表1 服务分布 服务名 服务器 安装目录 端口 data-script-exec 10.190.x.x 10.190.x.x /app/dt/data-script-exec 8090 安装脚本执行服务 修改配置文件application-dev.yml

查看更多 →