转发目标 选择“AMQP推送消息队列” 消息队列 单击“选择”，选择消息队列。 若没有消息队列，请新建消息队列，队列名称自定义且单个租户名下唯一，长度8-128，只能包含大写字母、小写字母、数字和指定特殊字符（如_-.:）。 若需要删除消息队列，单击消息队列右侧的“删除”即可。 说明：

查看更多 →

创建FlinkServer作业写入数据至Kafka消息队列 本章节适用于 MRS 3.1.2及之后的版本。 操作场景 本章节介绍Kafka作为source表或者sink表的DDL定义，以及创建表时使用的WITH参数和代码示例，并指导如何在FlinkServer作业管理页面操作。 本示例以安全模式Kafka为例。

查看更多 →

通过配置容器内核参数增大监听队列长度 使用场景 net.core.somaxconn默认监听队列（backlog）长度为128，当服务繁忙时，如果连接请求超过了监听队列的长度，新的连接请求将会被拒绝。为了避免这种情况的发生，您可以通过配置内核参数net.core.somaxconn来增大监听队列的长度。

查看更多 →

PERF03-06 选择合适的消息队列 风险等级 中 关键策略 三种不同版分布式消息服务的适用场景如下： Kafka：兼容开源Kafka，适用构建实时数据管道、流式数据处理、第三方解耦、流量削峰去谷等场景，有大规模、高可靠、高并发访问、可扩展且完全托管的特点。 RocketMQ：

查看更多 →

数据库对象名称的长度是否有限制？ 答：在创建数据库对象时命名长度不可超过63个字节，超过数据库对象名长度限制（63字节）的时候，数据库会将最后一个字节（而不是字符）截断，可能造成出现半个字符的情况。 父主题： FAQ

查看更多 →

TestPlan中调用获取字符串长度函数 函数名 $strLen(String A) 参数说明 String A：需要获取长度的原始字符串。 参数A支持以下类型： 字符串 局部参数 功能说明 获取指定字符串的长度，参数为计算的原始字符串。 使用场景 接口自动化用例中支持在以下场景中使用获取字符串长度函数：

查看更多 →

TestPlan中调用生成指定长度随机字符串函数 函数名 $random_string(intA) 功能说明 实现生成指定长度的随机字符串。其中，参数A支持以下几种类型： 数字 环境参数 局部参数 其它内置函数 使用场景 接口自动化用例中支持在以下场景使用生成指定长度随机字符串函数： 请求url路径

查看更多 →

Service，简称DMS）是一项基于高可用分布式集群技术的消息中间件服务，提供了可靠且可扩展的托管消息队列，用于收发消息和存储消息。分布式消息服务Kafka是一款基于开源社区版Kafka提供的消息队列服务，向用户提供可靠的全托管式的Kafka消息队列。 DLI 支持将作业的输出数据输出到DMS的Kafka实例中。创建DMS

查看更多 →

游订阅系统因突发流量崩溃。消息队列提供亿级消息堆积能力，3天的默认保留时长，消息消费系统可以错峰进行消息处理。 另外，在商品秒杀、抢购等流量短时间内暴增场景中，为了防止后端应用被压垮，可在前后端系统间使用RabbitMQ消息队列传递请求。 图3 消息队列应对秒杀大流量场景 系统解耦

查看更多 →

Service，简称DMS）是一项基于高可用分布式集群技术的消息中间件服务，提供了可靠且可扩展的托管消息队列，用于收发消息和存储消息。分布式消息服务Kafka是一款基于开源社区版Kafka提供的消息队列服务，向用户提供可靠的全托管式的Kafka消息队列。 DLI支持创建输入流从DMS的Kafka获取数据，作为作业的输入数据。创建DMS

查看更多 →

Service，简称DMS）是一项基于高可用分布式集群技术的消息中间件服务，提供了可靠且可扩展的托管消息队列，用于收发消息和存储消息。 分布式消息服务Kafka是一款基于开源社区版Kafka提供的消息队列服务，向用户提供可靠的全托管式的Kafka消息队列。 DLI支持创建输入流从DMS的Kafka获取数据，作为作业的输入数据。

查看更多 →

考下表配置完参数后，单击“确认”。 参数名 参数说明 转发目标 选择“MQTT推送消息队列” 推送Topic 输入要转发的MQTT Topic。 Topic队列名称自定义且单个租户名下唯一，最大长度 128位，支持大小写英文字符串、数字、下划线（_）、中划线（-）和斜杠（/），不支持除此之外的其他字符。

查看更多 →

单击"添加"进入"添加转发目标"页面，设置转发目标为"MQTT推送消息队列"，单击“预置服务接入凭证”预置接入凭证密钥（access_code）和接入凭证键值（access_key）。 图4 新建转发目标-转发至MQTT推送消息队列预置凭证 如果您之前预置过接入凭证，重新预置之后，之前的接入凭证密钥将不能再使用。

查看更多 →

源数据库表名和字段名长度检查 DDM->Oracle、MySQL->Oracle同步场景 表1 源数据库表名和字段名长度检查 预检查项 源数据库表名和字段名长度检查。 描述 源数据库表名和字段名长度不能超过30个字符。否则会导致同步失败 不通过提示及处理建议 不通过原因：源数据库存在超过30个字符的表名或者字段名。

查看更多 →

下游订阅系统因突发流量崩溃。消息队列提供亿级消息堆积能力，3天的默认保留时长，消息消费系统可以错峰进行消息处理。 另外，在商品秒杀、抢购等流量短时间内暴增场景中，为了防止后端应用被压垮，可在前后端系统间使用Kafka消息队列传递请求。 图3 消息队列应对秒杀大流量场景 日志同步

查看更多 →

DMS输出流 分布式消息服务Kafka是一款基于开源社区版Kafka提供的消息队列服务，向用户提供可靠的全托管式的Kafka消息队列。 DLI支持将作业的输出数据输出到DMS的Kafka实例中。 创建DMS Kafka输出流的语法与创建开源Apache Kafka输出流一样，具体请参见MRS

查看更多 →

华为云提供Kafka、RocketMQ、RabbitMQ三种不同版分布式消息服务，您可根据业务需求和不同版本优势来选择合适的消息队列。 PERF03-06 选择合适的消息队列 PERF03-07 选择合适的Kafka PERF03-08 选择合适的RocketMQ PERF03-09 选择合适的RabbitMQ

查看更多 →

ALM-50219 当前查询执行线程池等待队列的长度超过阈值 告警解释 系统每30秒周期性检查当前查询执行线程池等待队列的长度超过阈值，当检查到该值超出阈值（默认值为20）时产生该告警。 当前查询执行线程池等待队列的长度低于阈值时，告警清除。 告警属性 告警ID 告警级别 是否可自动清除

查看更多 →

题，可以增加只读实例应急。 不用作消息队列 发布订阅场景下，不建议作为消息队列使用。 强制 如没有非常特殊的需求，不建议将 Redis 当作消息队列使用。 Redis 当作消息队列使用，会有容量、网络、效率、功能方面的多种问题。 如需要消息队列，可使用高吞吐的Kafka或者高可靠的RocketMQ。

查看更多 →

填写连接器的描述信息，用于识别不同的连接器。 支持的动作 监听主题 监听队列 配置参数 表1 监听主题 参数 说明 主题名称 要监听的消息队列名称。 表2 监听队列 参数 说明 队列名称 要监听的消息队列名称。 父主题： 触发器

查看更多 →

分布式消息服务Kafka版（Distributed Message Service for Kafka）是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。 免费体验 图说Kafka 立即使用 成长地图 由浅入深，带您玩转Kafka

查看更多 →