未开启Kerberos认证的Kafka集群端口默认为9092，开启Kerberos认证的Kafka集群端口默认为21007。 登录 MRS Manager，选择“服务管理 > ZooKeeper > 实例”，获取ZooKeeper的quorumpeer实例的“管理IP”地址。 登录MRS

查看更多 →

Manager页面，选择“集群 > 服务 > Kafka”。单击“实例”，查看Kafka角色实例的IP地址。 kafka_topic_list 消费Kafka的Topic。 kafka_group_name Kafka消费组。 kafka_format 消费数据的格式化类型，JSONEachRow表示

查看更多 →

消息被消费后，没有删除，导致Kafka存储空间占满？ 消息被消费后，并不会被删除，只有超过老化时间，才会被删除。 您可以通过减小老化时间或者扩容存储空间，解决此问题。 父主题： Topic和分区问题

查看更多 →

当前管道中数据消费配置状态。 管道名称 当前数据管道的名称。 订阅器 系统预制的订阅模式，决定数据如何传递给消费者。 访问节点 当前数据的访问节点。 相关操作 数据消费开启后，如需关闭，则可在数据消费页面，单击“当前状态”后的，关闭数据消费。 父主题： 威胁运营

查看更多 →

1年3月20日后创建的实例，支持的加密套件为TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256。 2020年7月以及之后购买的实例，Kafka实例的每个代理允许客户端单IP连接的个数默认为1000个，在此之前购买的实例，Kafka实例的每个代理允许客户端单

查看更多 →

与开源Kafka的差异 分布式消息服务Kafka版在兼容开源Kafka基础上，对版本特性做了一定程度的定制和增强，所以，除了拥有开源Kafka的优点，分布式消息服务Kafka版提供了更多可靠、实用的特性。 表1 分布式消息服务Kafka版与开源Kafka的差异说明 对比类 对比项

查看更多 →

是用户指定的，“partitionId”是自动获取的。默认情况下，拓扑在启动后会先从ZooKeeper上的offset存放路径读取历史的offset，用作本次的消费起点，因此只需要正确的指定“zkRoot”和“id”，就可以继承历史记录的offset，不用从头开始消费。 场景2

查看更多 →

producer.KafkaProducer中定义的接口，在使用“kafka-console-producer.sh”时，默认使用此API。 旧Producer API 指kafka.producer.Producer中定义的接口，在使用“kafka-console-producer.sh

查看更多 →

操作流程 获取MQS连接信息，具体请参考开发准备。 若ROMA Connect实例的消息集成在开启SASL_SSL的同时，也开启了VPC内网明文访问，则VPC内无法使用SASL方式连接消息集成的Topic。 使用SASL方式连接消息集成的Topic时，建议在客户端所在主机的“/et

查看更多 →

一条数据的json格式， CS V格式表示逗号分隔的一行数据。 kafka_row_delimiter 每个消息体（记录）之间的分隔符。 kafka_handle_error_mode 设置为stream，会把每条消息处理的异常打印出来。需要创建视图，通过视图查询异常数据的具体处理异常。

查看更多 →

一条数据的json格式，CSV格式表示逗号分隔的一行数据。 kafka_row_delimiter 每个消息体（记录）之间的分隔符。 kafka_handle_error_mode 设置为stream，会把每条消息处理的异常打印出来。需要创建视图，通过视图查询异常数据的具体处理异常。

查看更多 →

华为云的激励是消费产生的激励，还是充值产生的激励？ 华为云的激励是消费产生的激励，即顾客消费后才会计入业绩。 父主题： 激励

查看更多 →

Connect的能力计算单元。每个RCU可分配到不同的集成能力上，包括数据集成、服务集成、消息集成、设备集成、组合应用等。根据分配的RCU数量，各集成能力提供不同的性能规格，分配的RCU数量越多，集成能力的性能规格越高。 连接器 ROMA Connect支持常见的数据源类型，如关

查看更多 →

详细介绍源端为Kafka/MQ的集群迁移流程和操作流程。 源端为数据库的数据迁移 Elasticsearch支持全文检索和Ad Hoc查询，所以经常作为关系型数据库（例如MySQL、 GaussDB for MySQL等）的补充，以此提升数据库的全文检索能力和高并发的Ad Hoc查询能力。

查看更多 →

创建IAM用户，并授予DMS for Kafka的权限，以达到用户之间权限的隔离。 购买Kafka实例 Kafka实例采用物理隔离的方式部署，租户独占Kafka实例。 创建Kafka Topic 创建用于存储消息的Topic，供生产者生产消息以及消费者订阅消息。 连接实例 客户端使用内网/

查看更多 →

“诊断详情”页面。 在页面顶部查看消息组异常项、失败项和正常项的数量。在“诊断维度”区域，单击包含异常项的维度名称，例如：重平衡，查看导致异常的可能原因、受影响的分区或者broker，以及解决消息堆积的建议。 图3 诊断详情 父主题： 管理消息

查看更多 →

除“华北-北京一”、“中东-利雅得”、“拉美-圣保罗一”和“拉美-圣地亚哥”以外的区域，集群版实例的SASL_SSL开关支持修改，具体步骤请参考修改实例的接入方式。单机版实例不支持SASL_SSL功能。 父主题： 实例问题

查看更多 →

回答：迁移速度的影响因素很多，比如迁移的对象大小、正在迁移的对象个数、网络传输情况等。在不考虑网络环境的情况下分析迁移速度慢的原因可能有下面几个方面： 大量的小对象 由于每个迁移任务的最大并发数是固定的，导致同时在迁移的对象数是有限制的。迁移前会列举对象，每个对象迁移完成后，都会对比源端和目的端是否一致。相比于迁

查看更多 →

优化消费者轮询（Polling） 方案概述 应用场景 在分布式消息服务Kafka版提供的原生Kafka SDK中，消费者可以自定义拉取消息的时长，如果需要长时间的拉取消息，只需要把poll(long)方法的参数设置合适的值即可。但是这样的长连接可能会对客户端和服务端造成一定的压力

查看更多 →

String 发送的实体的MIME类型。推荐用户默认使用application/json，如果API是对象、镜像上传等接口，媒体类型可按照流类型的不同进行确定。 缺省值：application/json X-Auth-Token 是 String 从IAM服务获取的用户Token。

查看更多 →

议。 跨语言支持 支持多语言的客户端 采用Scala和Java编写，支持多种语言的客户端。 采用Erlang编写，支持多种语言的客户端。 流量控制 待规划 支持client和user级别，通过主动设置可将流控作用于生产者或消费者。 RabbitMQ的流控基于Credit-Base

查看更多 →