检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
租户最大可以创建的实例个数，或者每个实例最大可以创建的标签个数。 used Integer 已创建的实例个数。 请求示例 GET https://{endpoint}/v1.0/{project_id}/quotas/dms 响应示例 状态码： 200 查询成功。 { "quotas" : { "resources"
表4 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误描述。 请求示例 升级id为instance_id的实例。 POST https://{endpoint}/v2/{project_id}/kafka/i
String 客户端Id 请求示例 查询消费组消息位点 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/message-offset 响应示例 状态码：200 查询成功
lag Integer 消息堆积数量 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/topics 响应示例 状态码：200 查询成功。 { "topics"
Integer 否 单页返回消息数，默认值为10。 offset Integer 否 查询的页码，默认值为1。 请求消息 请求参数 无 请求示例 无。 响应消息 响应参数 参数说明见表2。 表2 响应参数说明 参数 类型 说明 messages Array<Object> 消息列表，见表3。
client_id String 客户端Id 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/members 响应示例 状态码：200 查询成功。 { "members"
后台任务id。 protocol String 开启或者关闭的Kafka接入方式。 enable Boolean 开启动作或者关闭动作。 请求示例 实例第一次开启内网SASL_SSL，需要传入用户名及密码。 POST https://{endpoint}/v2/{project_id
String 消费组描述。 lag Long 堆积数。 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups 响应示例 状态码： 200 查询实例集群的所有消费组成功。 {
Array 否 实例的ID列表。 allFailure String 否 参数值为kafka，表示删除租户所有创建失败的Kafka实例。 请求示例 批量重启实例 POST https://{dms_endpoint}/v1.0/{project_id}/instances/action
et Long 最大消息位置（LEO）。 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 响应示例 状态码：200 查询指定消费组信息成功。 {
使用MirrorMaker跨集群同步数据 方案概述 应用场景 在以下场景，使用MirrorMaker进行不同集群间的数据同步，可以确保Kafka集群的可用性和可靠性。 备份和容灾：企业存在多个数据中心，为了防止其中一个数据中心出现问题，导致业务不可用，会将集群数据同步备份在多个不同的数据中心。
参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v1.0/{project_id}/instances/{instance_id}/ceshierarchy 响应示例 状态码： 200 查询成功。 { "dimensions"
分布式消息服务Kafka版的版本号格式为：消息引擎类型 x.y.z，其中消息引擎类型为Kafka，版本号具体含义如图1所示。 图1 版本号示例 版本支持情况 分布式消息服务Kafka版支持的版本：1.1.0、2.7、3.x（推荐） 版本生命周期 分布式消息服务Kafka版的版本生命周期如表1所示。
https://{Endpoint}/v3/projects”，其中{Endpoint}为IAM的终端节点，可以从地区和终端节点获取。接口的认证鉴权请参见认证鉴权。 响应示例如下，其中projects下的“id”即为项目ID。 { "projects": [ { "domain_id":
connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。 topic-name：Topic名称。 示例如下： [root@ecs-kafka bin]# ./kafka-topics.sh --bootstrap-server 192.168
--list 参数说明如下：connection-address表示Kafka实例的连接地址，在Kafka控制台的“基本信息 > 连接信息”中获取。 示例如下： [root@ecs-kafka bin]# ./kafka-consumer-groups.sh --bootstrap-server
消费者是从Topic订阅消息的一方，消费组是由一个或多个消费者组成的。同一个消费组内，一个消费者可同时消费多个分区，但一个分区在同一时刻只能被一个消费者消费。 图1 消费关系示例图 “auto.create.groups.enable”表示在消费者进入未创建的消费组时，会自动创建此消费组。 如果在配置参数中设置“auto
参数说明见表1。 表1 参数说明 参数 类型 必选 说明 engine String 是 消息引擎的类型。 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/products?engine={engine} 响应消息 响应参数 H
connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。 consumer-group-name：消费组名称。 示例如下： [root@ecs-kafka bin]# ./kafka-consumer-groups.sh --bootstrap-server
对话框中输入密码，系统会自动判定是否为弱密码）。 按照提示信息输入证书拥有者的信息，包含姓名、单位、组织名称、所在城市、所在省、所在国家，示例如下。 [root@ecs-kafka ~]# keytool -genkey -keystore server.keystore.jks
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
