大带宽。 应用层进行过载保护，保障优先业务的运行。 生产消息失败 检测：生产消息失败 恢复： 应用层进行重试，以应对暂时性故障；应用故障重试处理可参考“故障重试”。 当多次重试后仍无法写入成功，可将数据写入本地缓存，待服务可用后再写入实例。 当实例由于过载导致网络限制时，可参考“CPU

查看更多 →

使用RocketMQ实例生产消费消息的流程如下图所示。 图1 RocketMQ业务使用流程 创建用户并授权使用DMS for RocketMQ 创建IAM用户，并授予DMS for RocketMQ的权限，以达到用户之间权限的隔离。 购买RocketMQ实例 RocketMQ实例采

查看更多 →

什么是分布式消息服务Kafka版 Kafka是一个拥有高吞吐、可持久化、可水平扩展，支持流式数据处理等多种特性的分布式消息流处理中间件，采用分布式消息发布与订阅机制，在日志收集、流式数据传输、在线/离线系统分析、实时监控等领域有广泛的应用。 华为云分布式消息服务Kafka版是一款

查看更多 →

路由到分布式消息服务Kafka版 本章节介绍在创建事件流时如何配置分布式消息Kafka为事件目标。 前提条件 已开通分布式消息Kafka作为事件目标。 事件目标kafka不支持自定义证书。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流

查看更多 →

，然后将消息发送到Broker。 Consumer：从NameServer获取元数据，然后从Broker拉取消息。 支持的消息类型 分布式消息服务RocketMQ版支持4种消息类型。 普通消息：没有特殊功能的消息，区别于延迟消息、顺序消息和事务消息。 延迟消息/定时消息：生产者生

查看更多 →

云资源：包括“ 弹性云服务器 E CS ”，“云硬盘EVS”，“ 虚拟私有云VPC ”，“弹性IP”等。 云服务：包括“分布式缓存服务DCS”，“分布式消息服务DMS”等。 云上应用：包括“云容器引擎CCE”中的容器应用，“ 微服务引擎CSE ”中的微服务等。 任何云对象的创建都需要输入，创建成功后

查看更多 →

可选参数，用于补充说明该委托代理的详细信息。 - 单击“下一步”，进入“授权”页面。 在“选择策略”页签选择“DMS UserAccess”策略，并单击“下一步”。 DMS UserAccess策略：分布式消息服务普通用户权限（无实例创建、修改、删除、扩容、转储）。 在“设置最小授权范围”页签设置授权

查看更多 →

日志监控与告警：支持对存储在云日志服务中的日志数据进行关键词统计，通过在一定时间段内日志中关键字出现次数，实时监控服务运行状态。 日志转储：日志转储基于复制的转储机制，将需要长期存储的日志数据转储至对象存储服务（OBS）、数据接入服务（DIS）或分布式消息服务（DMS）中长期保存，并且不会在LTS被删除。

查看更多 →

DMS for RabbitMQ安全使用建议 安全性是华为云与您的共同责任。华为云负责云服务自身的安全，提供安全的云；作为租户，您需要合理使用云服务提供的安全能力对数据进行保护，安全地使用云。详情请参见责任共担。 本文提供了使用DMS for RabbitMQ过程中的安全最佳实践

查看更多 →

配置Kafka/DMS Kafka源端参数 作业中源连接为Kafka连接或DMS Kafka连接时，源端作业参数如表1所示。 表1 Kafka作为源端时的作业参数 参数类型 参数 说明 取值样例 基本参数 Topics 支持单个或多个topic。 est1,est2 数据格式 解析数据时使用的格式：

查看更多 →

分布式消息服务RabbitMQ版计费概述 通过阅读本文，您可以快速了解分布式消息服务RabbitMQ版的计费模式、计费项、续费、欠费等主要计费信息。 计费模式 分布式消息服务RabbitMQ版提供包年/包月和按需计费两种计费模式，以满足不同场景下的用户需求。包年/包月是一种预付费

查看更多 →

DMS for Kafka安全使用建议 安全性是华为云与您的共同责任。华为云负责云服务自身的安全，提供安全的云；作为租户，您需要合理使用云服务提供的安全能力对数据进行保护，安全地使用云。详情请参见责任共担。 本文提供了使用DMS for Kafka过程中的安全最佳实践，旨在为提高

查看更多 →

。 设置队列负载均衡 本章节介绍如何设置节点间队列的负载均衡，提升集群的利用率。 通过消息幂等实现消息去重 本章节描述了重复消息产生的原因，以及处理措施，避免因消息重复而对业务产生影响。 DMS for RabbitMQ安全使用建议 本章节提供了RabbitMQ使用过程中的安全最

查看更多 →

在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 单击Kafka实例的名称，进入实例详情页面。 在“连接信息 > SSL证书”后，单击“下载”，将SSL证书下载到本地。 解压证书zip包，获取JKS格式的SSL证书。 登录Linux系统的服务器，将JKS格式的SSL证书上传到服务器中。

查看更多 →

需要有一个线程poll各分区的消息就足够了，当在polling的线程发现Topic中有消息，可以唤醒其他线程一起消费消息，以达到快速响应的目的。如图2所示。 这种方案适用于对消费消息的实时性要求不高的应用场景。如果要求准实时消费消息，则建议保持所有消费者处于活跃状态。 图2 优化后的多线程消费方案

查看更多 →

CESReadOnlyAccess 云监控服务的只读权限，拥有该权限仅能查看云监控服务的数据。 云服务监控功能因为涉及需要查询其他云服务的实例资源，需要涉及服务支持策略授权特性，才可以正常使用，支持策略授权的云服务列表请参考: 使用IAM授权的云服务。 应用运维管理服务（AOM） （项目级服务） 区域级项目

查看更多 →

CESReadOnlyAccess 云监控服务的只读权限，拥有该权限仅能查看云监控服务的数据。 云服务监控功能因为涉及需要查询其他云服务的实例资源，需要涉及服务支持策略授权特性，才可以正常使用，支持策略授权的云服务列表请参考: 使用IAM授权的云服务。 应用运维管理服务（AOM） （项目级服务） 区域级项目

查看更多 →

支持IPv6的云服务 云服务产品分类 云服务 计算服务 ECS（弹性云服务器） BMS（裸金属服务器） HECS L（云耀云服务器 L实例 ） FunctionGraph（ 函数工作流 ） 容器服务 CCE（云容器引擎） CCI（云容器实例） ASM（应用服务网格） 网络服务 VPC（虚拟私有云）

查看更多 →

分布式消息服务RabbitMQ版计费模式概述 分布式消息服务RabbitMQ版提供包年/包月和按需计费两种计费模式，以满足不同场景下的用户需求。如您需要快速了解分布式消息服务RabbitMQ版的具体计费模式对应的具体价格，请参见分布式消息服务RabbitMQ版价格详情。 包年/包

查看更多 →

Server。 文档数据库服务 CDM 支持从文档数据库服务（Document Database Service，简称DDS）导出数据，暂不支持导入数据到DDS。 云搜索 服务 CDM支持从云搜索服务（Cloud Search Service，简称 CSS ）导入、导出数据。 数据接入服务 CDM支持导入数据到数据接入服务（Data

查看更多 →

DMS Kafka连接参数说明 连接DMS的Kafka队列时，相关参数如表1所示。 作业运行中禁止修改密码或者更换用户。在作业运行过程中修改密码或者更换用户，密码不会立即生效且作业会运行失败。 表1 DMS Kafka连接参数 参数名 说明 取值样例 名称 连接的名称，根据连接的

查看更多 →