Kafka实例创建Topic_分布式消息服务Kafka版_API参考_历史API_API V1_实例管理类接口_华为云

(1)

API 参考

文档版本 12

发布日期 2022-01-26

(2)

非经本公司书面许可，任何单位和个人不得擅自摘抄、复制本文档内容的部分或全部，并不得以任何形式传播。

商标声明

和其他华为商标均为华为技术有限公司的商标。

本文档提及的其他所有商标或注册商标，由各自的所有人拥有。

注意

您购买的产品、服务或特性等应受华为公司商业合同和条款的约束，本文档中描述的全部或部分产品、服务或特性可能不在您的购买或使用范围之内。除非合同另有约定，华为公司对本文档内容不做任何明示或暗示的声明或保证。

由于产品版本升级或其他原因，本文档内容会不定期进行更新。除非另有约定，本文档仅作为使用指导，本文档中的所有陈述、信息和建议不构成任何明示或暗示的担保。

(3)

1 ^{使用前必读}

1.1 概述

欢迎使用分布式消息服务Kafka版。分布式消息服务Kafka版是一款基于开源社区版 Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。使用分布式消息服务Kafka版，资源按需申请，按需配置Topic的分区与副本数量，即买即用，您将有更多精力专注于业务快速开发，不用考虑部署和运维。

本文档提供了分布式消息服务Kafka版API的描述、语法、参数说明及样例等内容。

须知

分布式消息服务Kafka版持续增加新的功能，将不可避免对现有接口有所调整，比如增加响应参数。

为了减少接口变更带来的影响，除了分布式消息服务Kafka版自身尽量做到接口向下兼容的同时，用户在使用过程中，应当接受出现返回内容（JSON格式）含有未使用的参数和值的现象，即能够正常忽略未使用的参数和值。

1.2 调用说明

分布式消息服务Kafka版提供了REST（Representational State Transfer）风格API，支持您通过HTTPS请求调用，调用方法请参见如何调用API。

1.3 终端节点

终端节点即调用API的请求地址，不同服务不同区域的终端节点不同，您可以从地区和终端节点中查询服务的终端节点。

1.4 约束与限制

● 您能创建的实例数上限，具体请参见服务配额。

(7)

● 更详细的限制请参见具体API的说明。

1.5 基本概念

● 帐号

用户注册帐号时，帐号对其所拥有的资源及云服务具有完全的访问权限，可以重置用户密码、分配用户权限等。由于帐号是付费主体，为了确保帐号安全，建议您不要直接使用帐号进行日常管理工作，而是创建用户并使用他们进行日常管理工作。

● 用户

由帐号在IAM中创建的用户，是云服务的使用人员，具有身份凭证（密码和访问密钥）。

在我的凭证下，您可以查看帐号ID和用户ID。通常在调用API的鉴权过程中，您需要用到帐号、用户和密码等信息。

● 区域：指云资源所在的物理位置，同一区域内可用区间内网互通，不同区域间内网不互通。通过在不同地区创建云资源，可以将应用程序设计的更接近特定客户的要求，或满足不同地区的法律或其他要求。

● 可用区：一个可用区是一个或多个物理数据中心的集合，有独立的风火水电，AZ 内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ 间通过高速光纤相连，以满足用户跨AZ构建高可用性系统的需求。

● 项目

区域默认对应一个项目，这个项目由系统预置，用来隔离物理区域间的资源（计算资源、存储资源和网络资源），以默认项目为单位进行授权，用户可以访问您帐号中该区域的所有资源。如果您希望进行更加精细的权限控制，可以在区域默认的项目中创建子项目，并在子项目中创建资源，然后以子项目为单位进行授权，使得用户仅能访问特定子项目中资源，使得资源的权限控制更加精确。

图1-1 项目隔离模型

同样在我的凭证下，您可以查看项目ID。

● 企业项目

企业项目是项目的升级版，针对企业不同项目间资源的分组和管理，是逻辑隔离。企业项目中可以包含多个区域的资源，且项目中的资源可以迁入迁出。

关于企业项目ID的获取及企业项目特性的详细信息，请参见《企业管理服务用户指南》。

(8)

2 ^{API 概览}

表2-1 实例管理类接口

API 说明

生命周期管理包括创建实例（按需）、修改实例信息、查询实例、删除

实例、重启实例。

实例管理包括重置密码、重置Manager密码、重启Manager、开启或关闭实例自动创建Topic功能、修改实例跨VPC访问的内网IP、查询Kafka集群元数据信息、查询消费组信息、重置消费组消费进度到指定位置、查询Kafka实例的协调器信息、新增Kafka实例指定Topic分区、修改分区的副本、

查询Topic的磁盘存储情况。

转储管理包括创建实例的转储节点、创建转储任务、查询转储任务

列表、修改转储任务的配额、查询单个转储任务、删除单个转储任务。

规格变更管理包括查询实例的扩容规格列表、实例规格变更。

主题管理包括查询Topic、创建Topic、修改Topic、批量删除 Topic、查询Topic详细信息。

用户管理包括查询用户列表、创建用户、删除用户、重置用户密

码、查询用户权限、设置用户权限。

消息查询包括查询消息、查询分区指定偏移量的消息、查询分区指

定时间段的消息、查询分区最早/最新的消息位置。

后台任务管理包括查询实例的后台任务列表、查询后台任务管理中的指

定记录、删除后台任务管理中的指定记录。

标签管理包括批量添加或删除实例标签、查询实例标签、查询项目

标签。

其他接口包括查询产品规格列表、查询可用区信息、查询维护时间

窗、查询实例在CES的监控层级关系。

(9)

3 ^{如何调用 API}

3.1 构造请求

本节如何构造REST API的请求，并以调用IAM服务的获取用户Token说明如何调用 API，该API获取用户的Token，Token可以用于调用其他API时鉴权。

您还可以通过这个视频教程了解如何构造请求调用API：https://

bbs.huaweicloud.com/videos/102987。

请求 URI

请求URI由如下部分组成。

{URI-scheme} :// {Endpoint} / {resource-path} ? {query-string}

尽管请求URI包含在请求消息头中，但大多数语言或框架都要求您从请求消息中单独传递它，所以在此单独强调。

● URI-scheme：

表示用于传输请求的协议，当前所有API均采用HTTPS协议。

● Endpoint：

指定承载REST服务端点的服务器域名或IP，不同服务不同区域的Endpoint不同，

您可以地区和终端节点获取。

例如IAM服务在“华北-北京一”区域的Endpoint为“iam.cn- north-1.myhuaweicloud.com”。

● resource-path：

资源路径，也即API访问路径。从具体API的URI模块获取，例如“获取用户 Token”API的resource-path为“/v3/auth/tokens”。

● query-string：

查询参数，是可选部分，并不是每个API都有查询参数。查询参数前面需要带一个

“？”，形式为“参数名=参数取值”，例如“limit=10”，表示查询不超过10条数据。

例如您需要获取IAM在“华北-北京一”区域的Token，则需使用“华北-北京一”区域的Endpoint（iam.cn-north-1.myhuaweicloud.com），并在获取用户Token的URI部分找到resource-path（/v3/auth/tokens），拼接起来如下所示。

(10)

https://iam.cn-north-1.myhuaweicloud.com/v3/auth/tokens

图3-1 URI 示意图

说明

为查看方便，在每个具体API的URI部分，只给出resource-path部分，并将请求方法写在一起。

这是因为URI-scheme都是HTTPS，同一个服务的Endpoint在同一个区域也相同，所以简洁起见将这两部分省略。

请求方法

HTTP请求方法（也称为操作或动词），它告诉服务你正在请求什么类型的操作。

● GET：请求服务器返回指定资源。

● PUT：请求服务器更新指定资源。

● POST：请求服务器新增资源或执行特殊操作。

● DELETE：请求服务器删除指定资源，如删除对象等。

● HEAD：请求服务器资源头部。

● PATCH：请求服务器更新资源的部分内容。当资源不存在的时候，PATCH可能会 去创建一个新的资源。

在获取用户Token的URI部分，您可以看到其请求方法为“POST”，则其请求为：

POST https://iam.cn-north-1.myhuaweicloud.com/v3/auth/tokens

请求消息头

附加请求头字段，如指定的URI和HTTP方法所要求的字段。例如定义消息体类型的请求头“Content-Type”，请求鉴权信息等。

如下公共消息头需要添加到请求中。

● Content-Type：消息体的类型（格式），必选，默认取值为“application/

json”，有其他取值时会在具体接口中专门说明。

● X-Auth-Token：用户Token，可选，当使用Token方式认证时，必须填充该字 段。用户Token也就是调用获取用户Token接口的响应值，该接口是唯一不需要认证的接口。

说明

API同时支持使用AK/SK认证，AK/SK认证是使用SDK对请求进行签名，签名过程会自动往请求中添加Authorization（签名认证信息）和X-Sdk-Date（请求发送的时间）请求头。

AK/SK认证的详细说明请参见AK/SK认证。

对于获取用户Token接口，由于不需要认证，所以只添加“Content-Type”即可，添加消息头后的请求如下所示。

(11)

POST https://iam.cn-north-1.myhuaweicloud.com/v3/auth/tokens Content-Type: application/json

请求消息体

请求消息体通常以结构化格式发出，与请求消息头中Content-type对应，传递除请求消息头之外的内容。若请求消息体中参数支持中文，则中文字符必须为UTF-8编码。

每个接口的请求消息体内容不同，也并不是每个接口都需要有请求消息体（或者说消息体为空），GET、DELETE操作类型的接口就不需要消息体，消息体具体内容需要根据具体接口而定。

对于获取用户Token接口，您可以从接口的请求部分看到所需的请求参数及参数说明。将消息体加入后的请求如下所示，加粗的斜体字段需要根据实际值填写，其中

username

为用户名，

domainname

为用户所属的帐号名称，

********

为用户登录密码，

xxxxxxxxxxxxxxxxxx

为project的名称，如“cn-north-1”，您可以从地区和终端节点获取。

说明

scope参数定义了Token的作用域，上面示例中获取的Token仅能访问project下的资源。您还可以设置Token作用域为某个帐号下所有资源或帐号的某个project下的资源，详细定义请参见获取用户Token。

POST https://iam.cn-north-1.myhuaweicloud.com/v3/auth/tokens Content-Type: application/json

{ "auth": { "identity": { "methods": [ "password"

],

"password": { "user": {

"name": "username", "password": "********", "domain": {

"name": "domainname"

} } } }, "scope": { "project": {

"name": "xxxxxxxxxxxxxxxxxx"

} } } }

到这里为止这个请求需要的内容就具备齐全了，您可以使用curl、Postman或直接编写代码等方式发送请求调用API。对于获取用户Token接口，返回的响应消息头中“x- subject-token”就是需要获取的用户Token。有了Token之后，您就可以使用Token认证调用其他API。

3.2 认证鉴权

调用接口有如下两种认证方式，您可以选择其中一种进行认证鉴权。

● Token认证：通过Token认证调用请求。

(12)

● AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。

推荐使用AK/SK认证，其安全性比Token认证要高。

Token 认证

说明

Token的有效期为24小时，需要使用一个Token鉴权时，可以先缓存起来，避免频繁调用。

Token在计算机系统中代表令牌（临时）的意思，拥有Token就代表拥有某种权限。

Token认证就是在调用API的时候将Token加到请求消息头，从而通过身份认证，获得操作API的权限。

Token可通过调用获取用户Token接口获取，调用本服务API需要project级别的 Token，即调用获取用户Token接口时，请求body中auth.scope的取值需要选择 project，如下所示。

{ "auth": { "identity": { "methods": [ "password"

],

"password": { "user": {

"name": "username", "password": "********", "domain": {

"name": "domainname"

} } } }, "scope": { "project": {

"name": "xxxxxxxx"

} } } }

获取Token后，再调用其他接口时，您需要在请求消息头中添加“X-Auth-Token”，

其值即为Token。例如Token值为“ABCDEFJ....”，则调用接口时将“X-Auth-Token:

ABCDEFJ....”加到请求消息头即可，如下所示。

POST https://iam.cn-north-1.myhuaweicloud.com/v3/auth/projects Content-Type: application/json

X-Auth-Token: ABCDEFJ....

您还可以通过这个视频教程了解如何使用Token认证：https://

bbs.huaweicloud.com/videos/101333。

AK/SK 认证

说明

AK/SK签名认证方式仅支持消息体大小12M以内，12M以上的请求请使用Token认证。

AK/SK认证就是使用AK/SK对请求进行签名，在请求时将签名信息添加到消息头，从而通过身份认证。

● AK(Access Key ID)：访问密钥ID。与私有访问密钥关联的唯一标识符；访问密钥 ID和私有访问密钥一起使用，对请求进行加密签名。

(13)

● SK(Secret Access Key)：与访问密钥ID结合使用的密钥，对请求进行加密签名，

可标识发送方，并防止请求被修改。

使用AK/SK认证时，您可以基于签名算法使用AK/SK对请求进行签名，也可以使用专门的签名SDK对请求进行签名。详细的签名方法和SDK使用方法请参见API签名指南。

须知

签名SDK只提供签名功能，与服务提供的SDK不同，使用时请注意。

3.3 返回结果

状态码

请求发送以后，您会收到响应，包含状态码、响应消息头和消息体。

状态码是一组从1xx到5xx的数字代码，状态码表示了请求响应的状态，完整的状态码列表请参见状态码。

对于获取用户Token接口，如果调用后返回状态码为“201”，则表示请求成功。

响应消息头

对应请求消息头，响应同样也有消息头，如“Content-type”。

对于获取用户Token接口，返回如图3-2所示的消息头，其中“x-subject-token”就是需要获取的用户Token。有了Token之后，您就可以使用Token认证调用其他API。

图3-2 获取用户 Token 响应消息头

(14)

响应消息体（可选）

响应消息体通常以结构化格式返回，与响应消息头中Content-type对应，传递除响应消息头之外的内容。

对于获取用户Token接口，返回如下消息体。为篇幅起见，这里只展示部分内容。

{ "token": {

"expires_at": "2019-02-13T06:52:13.855000Z", "methods": [

"password"

],

"catalog": [ {

"endpoints": [ {

"region_id": "XXXXXX", ...

当接口调用出错时，会返回错误码及错误信息说明，错误响应的Body体格式如下所示。

{ "error_msg": "The format of message is error", "error_code": "AS.0001"

}

其中，error_code表示错误码，error_msg表示错误描述信息。

(15)

4 ^快速入门

场景描述

您可以根据业务需要创建相应计算能力和存储空间的Kafka实例。

API调用方法请参考如何调用API。

前提条件

● 已获取IAM的Endpoint，具体请参见地区和终端节点。

● 已获取Kafka的Endpoint，具体请参见地区和终端节点。

创建 Kafka 实例

如下示例是创建Kafka实例的请求消息：

{ "name": "kafka-demo", "engine": "kafka", "engine_version": "2.3.0", "specification": "100MB", "storage_space": 600, "partition_num": 300,

"vpc_id": "60fc80a5-35db-45a9-acdb-0ef2361e1088",

"security_group_id": "d8c81e0f-de6a-4110-8c96-81af3eacb3d1", "subnet_id": "45767e73-a093-4a1c-8cdd-b8d664b34dcc", "available_zones": [

"72d50cedc49846b9b42c21495f38d81c"

], "product_id": "00300-30308-0--0", "kafka_manager_user": "test", "kafka_manager_password": "Z****x",

"storage_spec_code": "dms.physical.storage.high"

}

● name：实例名称，由您自行定义。

● engine：消息引擎，设置kafka。

● engine_version：消息引擎的版本。

● specification：Kafka实例的基准带宽。具体取值范围，请参考“创建实例（按需）”章节。

● storage_space：消息存储空间，单位GB。具体取值范围，请参考“创建实例（按需）”章节。

(16)

● partition_num：Kafka实例的最大分区数量。具体取值范围，请参考“创建实例

（按需）”章节。

● vpc_id：Kafka实例所在的VPC（虚拟私有云）的ID。您可以在虚拟私有云控制台中查询，也可以通过查询VPC列表API查询。

● security_group_id：安全组ID。您可以在虚拟私有云控制台中查询，也可以通过查询安全组列表API查询。

● subnet_id：VPC内子网的网络ID。您可以在虚拟私有云控制台中查询，也可以通过查询子网列表API查询。

● available_zones：创建节点到指定的AZ ID，该参数不能为空数组或者数组的值为空，请参考“查询可用区信息”章节获取。

● product_id：产品标识。请参考“查询产品规格列表”章节获取。

● kafka_manager_user：登录Kafka Manager的用户名，由您自行定义。

● kafka_manager_password：登录Kafka Manager的用户名密码，由您自行定义。

● storage_spec_code：存储IO规格。具体取值范围，请参考“创建实例（按需）”

章节。

(17)

5 API V2（推荐）

5.1 生命周期管理

5.1.1 创建实例（按需）

功能介绍

创建实例，该接口创建的实例为按需计费的方式。

调试

您可以在API Explorer中调试该接口。

URI

POST /v2/{project_id}/instances

表5-1 路径参数

参数是否必选参数类型描述

project_id 是 String 项目ID。

(18)

请求参数

表5-2 请求 Body 参数

name 是 String 实例名称。

由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。

description 否 String 实例的描述信息。

长度不超过1024的字符串。

说明\与"在json报文中属于特殊字符，

如果参数值中需要显示\或者"字符，请在字符前增加转义字符\，比如\或者"。

engine 是 String 消息引擎。取值填写为：

kafka。

engine_versio

n 是 String 消息引擎的版本。取值填写为：

1.1.0和2.3.0。

specification 是 String Kafka实例的基准带宽，表示单位时间内传送的最大数据量，单位MB。取值范围：

● 100MB

● 300MB

● 600MB

● 1200MB

storage_space 是 Integer 消息存储空间，单位GB。

● Kafka实例规格为100MB 时，存储空间取值范围 600GB ~ 90000GB。

● Kafka实例规格为1200MB，

存储空间取值范围4800GB ~ 90000GB。

(19)

partition_num 否 Integer Kafka实例的最大分区数量。

● 参数specification为100MB 时，取值300

access_user 否 String 当ssl_enable为true时，该参数必选，ssl_enable为false时，该参数无效。

认证用户名，只能由英文字母、

数字、中划线组成，长度为 4~64的字符。

password 否 String 当ssl_enable为true时，该参数必选，ssl_enable为false时，该参数无效。

实例的认证密码。

复杂度要求：

● 输入长度为8到32位的字符串。

● 必须包含如下四种字符中的两种组合：

– 小写字母 – 大写字母 – 数字

– 特殊字符包括（`~!@#$

%^&*()-_=+|

[{}]:'",<.>/?）

vpc_id 是 String 虚拟私有云ID。

获取方法如下：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。

security_grou

p_id 是 String 指定实例所属的安全组。

获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。

(20)

subnet_id 是 String 子网信息。

获取方法如下：登录虚拟私有云服务的控制台界面，单击VPC下的子网，进入子网详情页面，查找网络ID。

available_zon

es 是 Array of

strings 创建节点到指定且有资源的可用区ID。该参数不能为空数组或者数组的值为空。创建Kafka实例，支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时，用逗号分隔开。

product_id 是 String 产品标识。

kafka_manag

er_user 是 String 表示登录Kafka Manager的用户名。只能由英文字母、数字、中划线组成，长度为4~64的字符。

kafka_manag

er_password 是 String 表示登录Kafka Manager的密码。

复杂度要求：

● 输入长度为8到32位的字符串。

● 必须包含如下四种字符中的两种组合：

– 小写字母 – 大写字母 – 数字

– 特殊字符包括（`~!@#$

%^&*()-_=+|

[{}]:'",<.>/?）

maintain_begi

n 否 String 维护时间窗开始时间，格式为

HH:mm。

● 维护时间窗开始和结束时间必须为指定的时间段。

● 开始时间必须为22:00、

02:00、06:00、10:00、

14:00和18:00。

● 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00。

(21)

maintain_end 否 String 维护时间窗结束时间，格式为 HH:mm。

● 结束时间在开始时间基础上加四个小时，即当开始时间为22:00时，结束时间为 02:00。

● 该参数不能单独为空，若该值为空，则开始时间也为空，系统分配一个默认结束时间06:00。

enable_publici

p 否 Boolean 是否开启公网访问功能。默认不

开启公网。

● true：开启

● false：不开启 public_bandwi

dth 否 Integer 表示公网带宽，单位是Mbit/s。

取值范围：

● Kafka实例规格为100MB 时，公网带宽取值范围3到 900，且必须为实例节点个数的倍数。

publicip_id 否 String 实例绑定的弹性IP地址的ID。

以英文逗号隔开多个弹性IP地址的ID。

如果开启了公网访问功能（即 enable_publicip为true），该字段为必选。

ssl_enable 否 Boolean 是否打开SSL加密访问。

● true：打开SSL加密访问。

● false：不打开SSL加密访问。

(22)

参数是否必选参数类型描述 retention_poli

cy 否 String 磁盘的容量到达容量阈值后，对

于消息的处理策略。

取值如下：

● produce_reject：表示拒绝消息写入。

● time_base：表示自动删除最老消息。

connector_en

able 否 Boolean 是否开启消息转储功能。

默认不开启消息转储。

enable_auto_t

opic 否 Boolean 是否打开kafka自动创建topic功能。

● true：开启

● false：关闭

当您选择开启，表示生产或消费一个未创建的Topic时，会自动创建一个包含3个分区和3个副本的Topic。

storage_spec_

code 是 String 存储IO规格。取值范围：

● 参数specification为100MB 时，取值dms.physical.storage.high或者dms.physical.storage.ultra

● 参数specification为300MB 时，取值dms.physical.storage.high或者dms.physical.storage.ultra

● 参数specification为600MB 时，取值dms.physical.storage.ultra

● 参数specification为1200MB 时，取值dms.physical.storage.ultra存储IO规格。如何选择磁盘类型请参考磁盘类型及性能介绍。

enterprise_pro

ject_id 否 String 企业项目ID。若为企业项目帐

号，该参数必填。

tags 否 Array of

TagEntity

objects

标签列表。

(23)

表5-3 TagEntity

key 否 String 键。最大长度36个unicode字

符。

key不能为空，不能为空字符串。

不能包含下列字符：非打印字符 ASCII(0-31)，“=”,“*”,

“<”,“>”,“\”,“,”,“|”,

“/”。

value 否 String 值。每个值最大长度43个

unicode字符。

value不能为空，可以空字符串。

不能包含下列字符：非打印字符 ASCII(0-31), “=”,“*”,“<”,

“>”,“\”,“,”,“|”,“/”。

响应参数

状态码： 200

表5-4 响应 Body 参数

参数参数类型描述

instance_id String 实例ID

请求示例

POST https://{endpoint}/v2/{project_id}/instances { "name" : "kafka-test",

"description" : "", "engine" : "kafka", "engine_version" : "1.1.0", "storage_space" : 300, "kafka_manager_user" : "root", "kafka_manager_password" : "**********", "vpc_id" : "23921d2a-****-****-****-5f2fa5327a48",

"security_group_id" : "2e888928-****-****-****-e36c6520d473", "subnet_id" : "37bb12c9-****-****-****-ae8f7d336ab6",

"available_zones" : [ "a0865121f83b41cbafce65930a22a6e8" ], "product_id" : "00300-30310-0--0",

"maintain_begin" : "22:00", "maintain_end" : "02:00", "ssl_enable" : true, "enable_publicip" : true,

"publicip_id" : "6db1129f-16af-455d-8d54-d7ab9f277393,bb200202-423f-49e4- bae7-8ab3c36cdc3e,ca8801e8-6620-42af-b506-a5c9ee395466",

"access_user" : "root",

(24)

"password" : "**********", "enterprise_project_id" : "0", "specification" : "300MB", "partition_num" : 900,

"retention_policy" : "time_base", "public_boundwidth" : 3, "connector_enable" : false, "enable_auto_topic" : true,

"storage_spec_code" : "dms.physical.storage.ultra", "tags" : [ {

"key" : "key1", "value" : "value1"

}, {

"key" : "key2", "value" : "value2"

} ] }

响应示例

状态码： 200 创建实例成功。

{ "instance_id" : "8959ab1c-7n1a-yyb1-a05t-93dfc361b32d"

}

状态码

状态码描述

200 创建实例成功。

错误码

请参见错误码。

5.1.2 查询所有实例列表

功能介绍

查询租户的实例列表，支持按照条件查询。

调试

URI

GET /v2/{project_id}/instances

(25)

表5-5 路径参数

表5-6 Query 参数

engine 否 String 消息引擎：kafka。

name 否 String 实例名称。

instance_id 否 String 实例ID。

status 否 String 实例状态。

include_failur

e 否 String 是否返回创建失败的实例数。

当参数值为“true”时，返回创建失败的实例数。参数值为

“false”或者其他值，不返回创建失败的实例数。

exact_match_

name 否 String 是否按照实例名称进行精确匹配

查询。

默认为“false”，表示模糊匹配实例名称查询。若参数值为

“true”表示按照实例名称进行精确匹配查询。

enterprise_pro

ject_id 否 String 企业项目ID。

请求参数

无

响应参数

状态码： 200

instances Array of

ShowInstanc eResp objects

实例列表

instance_num Integer 实例数量。

(26)

表5-8 ShowInstanceResp

name String 实例名称。

engine String 引擎。

engine_versio

n String 版本。

specification String 实例规格。

storage_space Integer 消息存储空间，单位：GB。

partition_num String Kafka实例的分区数量。

used_storage_

space Integer 已使用的消息存储空间，单位：GB。

connect_addr

ess String 实例连接IP地址。

port Integer 实例连接端口。

status String 实例的状态。

instance_id String 实例ID。

resource_spec

_code String 资源规格标识。

● dms.instance.kafka.cluster.c3.mini：Kafka实例的基准带宽为100MByte/秒。

● dms.instance.kafka.cluster.c3.small.2：Kafka 实例的基准带宽为300MByte/秒。

● dms.instance.kafka.cluster.c3.middle.2：

Kafka实例的基准带宽为600MByte/秒。

● dms.instance.kafka.cluster.c3.high.2：Kafka 实例的基准带宽为1200MByte/秒。

charging_mod

e Integer 付费模式，1表示按需计费，0表示包年/包月计

费。

vpc_id String VPC ID。

vpc_name String VPC的名称。

created_at String 完成创建时间。

格式为时间戳，指从格林威治时间 1970年01月 01日00时00分00秒起至指定时间的偏差总毫秒数。

user_id String 用户ID。

user_name String 用户名。

order_id String 订单ID，只有在包周期计费时才会有order_id 值，其他计费方式order_id值为空。

(27)

参数参数类型描述 maintain_begi

n String 维护时间窗开始时间，格式为HH:mm:ss。

maintain_end String 维护时间窗结束时间，格式为HH:mm:ss。

enable_publici

p Boolean 实例是否开启公网访问功能。

● true：开启

● false：未开启 management

_connect_add ress

String Kafka实例的KafkaManager连接地址。

ssl_enable Boolean 是否开启安全认证。

● true：开启

● false：未开启 enterprise_pro

ject_id String 企业项目ID。

is_logical_volu

me Boolean 实例扩容时用于区分老实例与新实例。

● true：新创建的实例，允许磁盘动态扩容不需要重启。

● false：老实例

extend_times Integer 实例扩容磁盘次数，如果超过20次则无法扩容磁盘。

enable_auto_t

opic Boolean 是否打开kafka自动创建topic功能。

● true：开启

● false：关闭

type String 实例类型：集群，cluster。

product_id String 产品标识。

security_grou

p_id String 安全组ID。

security_grou

p_name String 租户安全组名称。

subnet_id String 子网ID。

available_zon

es Array of

strings 实例节点所在的可用区，返回“可用区ID”。

total_storage_

space Integer 总共消息存储空间，单位：GB。

public_connec

t_address String 实例公网连接IP地址。当实例开启了公网访问，

实例才包含该参数。

(28)

参数参数类型描述 storage_resou

rce_id String 存储资源ID。

storage_spec_

code String IO规格。

service_type String 服务类型。

storage_type String 存储类型。

retention_poli

cy String 消息老化策略。

kafka_public_

status String Kafka公网开启状态。

public_bandwi

dth Integer 公网带宽。

kafka_manag

er_user String 登录Kafka Manager的用户名。

enable_log_co

llection Boolean 是否开启消息收集功能。

cross_vpc_info String 跨VPC访问信息。

ipv6_enable Boolean 是否开启ipv6。

ipv6_connect_

addresses Array of

strings IPv6的连接地址。

connector_en

able Boolean 是否开启转储。

connector_id String 转储任务ID。

rest_enable Boolean 是否开启Kafka rest功能。

rest_connect_

address String Kafka rest连接地址。

message_quer

y_inst_enable Boolean 是否开启消息查询功能。

vpc_client_pla

in Boolean 是否开启VPC明文访问。

support_featu

res String Kafka实例支持的特性功能。

trace_enable Boolean 是否开启消息轨迹功能。

pod_connect_

address String 租户侧连接地址。

(29)

参数参数类型描述 disk_encrypte

d Boolean 是否开启磁盘加密。

kafka_private _connect_add ress

String Kafka实例私有连接地址。

ces_version String 云监控版本。

tags Array of

TagEntity

objects

标签列表。

dr_enable Boolean 是否为容灾实例。

key String 键。最大长度36个unicode字符。

不能包含下列字符：非打印字符ASCII(0-31)，

“=”,“*”,“<”,“>”,“\”,“,”,“|”,

“/”。

value String 值。每个值最大长度43个unicode字符。

不能包含下列字符：非打印字符ASCII(0-31),

“=”,“*”,“<”,“>”,“\”,“,”,“|”,

“/”。

请求示例

GET https://{endpoint}/v2/{project_id}/instances

响应示例

状态码： 200

查询所有实例列表成功。

{ "instances" : [ {

"name" : "kafka-2085975099", "engine" : "kafka",

"port" : 9092, "status" : "RUNNING", "type" : "cluster", "specification" : "100MB", "engine_version" : "1.1.0",

"connect_address" : "192.168.0.100,192.168.0.61,192.168.0.72", "instance_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",

(30)

"resource_spec_code" : "dms.instance.kafka.cluster.c3.mini", "charging_mode" : 1,

"vpc_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx", "vpc_name" : "dms-test",

"created_at" : "1585618587087", "product_id" : "00300-30308-0--0",

"security_group_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx", "security_group_name" : "Sys-default",

"subnet_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",

"available_zones" : [ "38b0f7a602344246bcb0da47b5d548e7" ], "user_id" : "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",

"user_name" : "paas_dms", "kafka_manager_user" : "root", "maintain_begin" : "02:00:00", "maintain_end" : "06:00:00", "enable_log_collection" : false, "storage_space" : 492, "total_storage_space" : 600, "used_storage_space" : 25, "partition_num" : "300", "enable_publicip" : false, "ssl_enable" : false,

"management_connect_address" : "https://192.168.0.100:9999",

"cross_vpc_info" : "{\"192.168.0.61\":{\"advertised_ip\":\"192.168.0.61\",\"port\":9011,\"port_id\":

\"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx\"},\"192.168.0.72\":{\"advertised_ip\":\"192.168.0.72\",\"port\":

9011,\"port_id\":\"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx\"},\"192.168.0.100\":{\"advertised_ip\":

\"192.168.0.100\",\"port\":9011,\"port_id\":\"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx\"}}", "storage_resource_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",

"storage_spec_code" : "dms.physical.storage.ultra", "service_type" : "advanced",

"storage_type" : "hec", "enterprise_project_id" : "0", "is_logical_volume" : true, "extend_times" : 0,

"retention_policy" : "produce_reject", "ipv6_enable" : false,

"ipv6_connect_addresses" : [ ], "connector_enable" : false, "connector_id" : "", "rest_enable" : false, "rest_connect_address" : "", "kafka_public_status" : "closed", "public_boundwidth" : 0,

"message_query_inst_enable" : true, "vpc_client_plain" : false,

"support_features" :

"kafka.new.pod.port,feature.physerver.kafka.topic.modify,feature.physerver.kafka.topic.accesspolicy,message_t race_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic,roma_app_enable,features.log.c ollection,auto_topic_switch,feature.physerver.kafka.user.manager",

"trace_enable" : false, "agent_enable" : false,

"pod_connect_address" : "100.86.75.15:9080,100.86.142.77:9080,100.86.250.167:9080", "disk_encrypted" : false,

"kafka_private_connect_address" : "192.168.0.61:9092,192.168.0.100:9092,192.168.0.72:9092", "enable_auto_topic" : false,

"ces_version" : "linux"

} ],

"instance_num" : 1 }

状态码

状态码描述

200 查询所有实例列表成功。

(31)

错误码

5.1.3 查询指定实例

功能介绍

查询指定实例的详细信息。

调试

URI

GET /v2/{project_id}/instances/{instance_id}

表5-10 路径参数

instance_id 是 String 实例ID。

请求参数

无

响应参数

状态码： 200

name String 实例名称。

engine String 引擎。

engine_versio

n String 版本。

specification String 实例规格。

storage_space Integer 消息存储空间，单位：GB。

partition_num String Kafka实例的分区数量。

used_storage_

space Integer 已使用的消息存储空间，单位：GB。

(32)

参数参数类型描述 connect_addr

ess String 实例连接IP地址。

port Integer 实例连接端口。

status String 实例的状态。

resource_spec

_code String 资源规格标识。

● dms.instance.kafka.cluster.c3.mini：Kafka实例的基准带宽为100MByte/秒。

● dms.instance.kafka.cluster.c3.small.2：Kafka 实例的基准带宽为300MByte/秒。

● dms.instance.kafka.cluster.c3.middle.2：

Kafka实例的基准带宽为600MByte/秒。

● dms.instance.kafka.cluster.c3.high.2：Kafka 实例的基准带宽为1200MByte/秒。

charging_mod

e Integer 付费模式，1表示按需计费，0表示包年/包月计

费。

vpc_id String VPC ID。

vpc_name String VPC的名称。

created_at String 完成创建时间。

格式为时间戳，指从格林威治时间 1970年01月 01日00时00分00秒起至指定时间的偏差总毫秒数。

user_id String 用户ID。

user_name String 用户名。

order_id String 订单ID，只有在包周期计费时才会有order_id 值，其他计费方式order_id值为空。

maintain_begi

n String 维护时间窗开始时间，格式为HH:mm:ss。

maintain_end String 维护时间窗结束时间，格式为HH:mm:ss。

enable_publici

p Boolean 实例是否开启公网访问功能。

● true：开启

● false：未开启 management

_connect_add ress

String Kafka实例的KafkaManager连接地址。

(33)

ssl_enable Boolean 是否开启安全认证。

● true：开启

● false：未开启 enterprise_pro

ject_id String 企业项目ID。

is_logical_volu

me Boolean 实例扩容时用于区分老实例与新实例。

● true：新创建的实例，允许磁盘动态扩容不需要重启。

● false：老实例

extend_times Integer 实例扩容磁盘次数，如果超过20次则无法扩容磁盘。

enable_auto_t

opic Boolean 是否打开kafka自动创建topic功能。

● true：开启

● false：关闭

type String 实例类型：集群，cluster。

product_id String 产品标识。

security_grou

p_id String 安全组ID。

security_grou

p_name String 租户安全组名称。

subnet_id String 子网ID。

available_zon

es Array of

strings 实例节点所在的可用区，返回“可用区ID”。

total_storage_

space Integer 总共消息存储空间，单位：GB。

public_connec

t_address String 实例公网连接IP地址。当实例开启了公网访问，

实例才包含该参数。

storage_resou

rce_id String 存储资源ID。

storage_spec_

code String IO规格。

service_type String 服务类型。

storage_type String 存储类型。

retention_poli

cy String 消息老化策略。

(34)

参数参数类型描述 kafka_public_

status String Kafka公网开启状态。

public_bandwi

dth Integer 公网带宽。

kafka_manag

er_user String 登录Kafka Manager的用户名。

enable_log_co

llection Boolean 是否开启消息收集功能。

cross_vpc_info String 跨VPC访问信息。

ipv6_enable Boolean 是否开启ipv6。

ipv6_connect_

addresses Array of

strings IPv6的连接地址。

connector_en

able Boolean 是否开启转储。

connector_id String 转储任务ID。

rest_enable Boolean 是否开启Kafka rest功能。

rest_connect_

address String Kafka rest连接地址。

message_quer

y_inst_enable Boolean 是否开启消息查询功能。

vpc_client_pla

in Boolean 是否开启VPC明文访问。

support_featu

res String Kafka实例支持的特性功能。

trace_enable Boolean 是否开启消息轨迹功能。

pod_connect_

address String 租户侧连接地址。

disk_encrypte

d Boolean 是否开启磁盘加密。

kafka_private _connect_add ress

String Kafka实例私有连接地址。

ces_version String 云监控版本。

tags Array of

TagEntity

objects

标签列表。

dr_enable Boolean 是否为容灾实例。

(35)

key String 键。最大长度36个unicode字符。

不能包含下列字符：非打印字符ASCII(0-31)，

“=”,“*”,“<”,“>”,“\”,“,”,“|”,

“/”。

value String 值。每个值最大长度43个unicode字符。

不能包含下列字符：非打印字符ASCII(0-31),

“=”,“*”,“<”,“>”,“\”,“,”,“|”,

“/”。

请求示例

GET https://{endpoint}/v2/{project_id}/instances/{instance_id}

响应示例

状态码： 200 查询实例成功。

{ "name" : "kafka-2085975099", "engine" : "kafka",

"port" : 9092, "status" : "RUNNING", "type" : "cluster", "specification" : "100MB", "engine_version" : "1.1.0",

"connect_address" : "192.168.0.100,192.168.0.61,192.168.0.72", "instance_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx", "resource_spec_code" : "dms.instance.kafka.cluster.c3.mini", "charging_mode" : 1,

"vpc_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx", "vpc_name" : "dms-test",

"created_at" : "1585618587087", "product_id" : "00300-30308-0--0",

"security_group_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx", "security_group_name" : "Sys-default",

"subnet_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",

"available_zones" : [ "38b0f7a602344246bcb0da47b5d548e7" ], "user_id" : "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",

"user_name" : "paas_dms", "kafka_manager_user" : "root", "maintain_begin" : "02:00:00", "maintain_end" : "06:00:00", "enable_log_collection" : false, "storage_space" : 492, "total_storage_space" : 600, "used_storage_space" : 25, "partition_num" : "300", "enable_publicip" : false,

(36)

"ssl_enable" : false,

"management_connect_address" : "https://192.168.0.100:9999",

"cross_vpc_info" : "{\"192.168.0.61\":{\"advertised_ip\":\"192.168.0.61\",\"port\":9011,\"port_id\":\"xxxxxxxxxxxx-xxxx-xxxx-xxxxxxxxxxxx\"},\"192.168.0.72\":{\"advertised_ip\":\"192.168.0.72\",\"port\":9011,\"port_id\":

\"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx\"},\"192.168.0.100\":{\"advertised_ip\":\"192.168.0.100\",\"port\":

9011,\"port_id\":\"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx\"}}", "storage_resource_id" : "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx", "storage_spec_code" : "dms.physical.storage.ultra",

"service_type" : "advanced", "storage_type" : "hec", "enterprise_project_id" : "0", "is_logical_volume" : true, "extend_times" : 0,

"retention_policy" : "produce_reject", "ipv6_enable" : false,

"ipv6_connect_addresses" : [ ], "connector_enable" : false, "connector_id" : "", "rest_enable" : false, "rest_connect_address" : "", "kafka_public_status" : "closed", "public_boundwidth" : 0,

"message_query_inst_enable" : true, "vpc_client_plain" : false,

"support_features" :

"kafka.new.pod.port,feature.physerver.kafka.topic.modify,feature.physerver.kafka.topic.accesspolicy,message_t race_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic,roma_app_enable,features.log.c ollection,auto_topic_switch,feature.physerver.kafka.user.manager",

"trace_enable" : false, "agent_enable" : false,

"pod_connect_address" : "100.86.75.15:9080,100.86.142.77:9080,100.86.250.167:9080", "disk_encrypted" : false,

"kafka_private_connect_address" : "192.168.0.61:9092,192.168.0.100:9092,192.168.0.72:9092", "enable_auto_topic" : false,

"ces_version" : "linux"

}

状态码

状态码描述

200 查询实例成功。

错误码

5.1.4 删除指定的实例

功能介绍

删除指定的实例，释放该实例的所有资源。

调试

URI

DELETE /v2/{project_id}/instances/{instance_id}

(37)

表5-13 路径参数

请求参数

无

响应参数

无

请求示例

DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}

响应示例

无

状态码

状态码描述

204 删除指定的实例成功。

错误码

5.1.5 修改实例信息

功能介绍

修改实例的名称和描述信息。

调试

URI

PUT /v2/{project_id}/instances/{instance_id}

(38)

表5-14 路径参数

请求参数

name 否 String 实例名称。

由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。

description 否 String 实例的描述信息。

长度不超过1024的字符串。

说明\与"在json报文中属于特殊字符，

如果参数值中需要显示\或者"字符，请在字符前增加转义字符\，比如\或者"。

maintain_begi

n 否 String 维护时间窗开始时间，格式为

HH:mm:ss。

● 开始时间必须为22:00:00、

02:00:00、06:00:00、

10:00:00、14:00:00和 18:00:00。

● 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00:00。

(39)

maintain_end 否 String 维护时间窗结束时间，格式为 HH:mm:ss。

● 结束时间在开始时间基础上加四个小时，即当开始时间为22:00:00时，结束时间为 02:00:00。

● 该参数不能单独为空，若该值为空，则开始时间也为空。系统分配一个默认结束时间06:00:00。

security_grou

p_id 否 String 安全组ID。

retention_poli

cy 否 String 容量阈值策略。支持两种策略

模式：

● produce_reject: 生产受限

● time_base: 自动删除 enterprise_pro

ject_id 否 String 企业项目。

响应参数

无

请求示例

● 修改实例的名称和描述。

PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}

{ "name" : "kafka001",

"description" : "kafka description"

}

● 修改实例的名称、描述和维护时间窗。

{ "name" : "dms002",

"description" : "instance description", "maintain_begin" : "02:00:00", "maintain_end" : "06:00:00"

}

● 修改容量阈值策略。

{

(40)

"retention_policy" : "time_base"

}

响应示例

无

状态码

状态码描述

204 修改实例信息成功

错误码

5.1.6 批量重启或删除实例

功能介绍

批量重启或删除实例。

在实例重启过程中，客户端的生产与消费消息等请求会被拒绝。

实例删除后，实例中原有的数据将被删除，且没有备份，请谨慎操作。

调试

URI

POST /v2/{project_id}/instances/action

表5-16 路径参数

请求参数

instances 否 Array of

strings 实例的ID列表。

(41)

action 是 String 对实例的操作：restart、delete all_failure 否 String 参数值为kafka，表示删除租户

所有创建失败的Kafka实例。

响应参数

状态码： 200

results Array of

results

objects

修改实例的结果。

表5-19 results

result String 操作结果。 - 'success: 操作成功' - 'failed: 操作失败'

instance String 实例ID。

请求示例

● 批量重启实例。

POST https://{endpoint}/v2/{project_id}/instances/action { "action" : "restart",

"instances" : [ "54602a9d-5e22-4239-9123-77e350df4a34", "7166cdea- dbad-4d79-9610-7163e6f8b640" ]

}

● 批量删除实例。

POST https://{endpoint}/v2/{project_id}/instances/action { "action" : "delete",

"instances" : [ "54602a9d-5e22-4239-9123-77e350df4a34", "7166cdea- dbad-4d79-9610-7163e6f8b640" ]

}

● 删除所有创建失败的实例。

POST https://{endpoint}/v2/{project_id}/instances/action { "action" : "delete",

(42)

"allFailure" : "kafka"

}

响应示例

状态码： 200

批量重启或删除实例成功。

{ "results" : [ { "result" : "success",

"instance" : "019cacb7-4ff0-4d3c-9f33-f5f7b7fdc0e6"

} ] }

状态码

状态码描述

200 批量重启或删除实例成功。

错误码

5.2 实例管理

5.2.1 重置密码

功能介绍

重置密码。

调试

URI

POST /v2/{project_id}/instances/{instance_id}/password

表5-20 路径参数

(43)

请求参数

new_passwor

d 否 String 8-32个字符。至少包含以下字

符中的3种：

● 大写字母

● 小写字母

● 数字

● 特殊字符`~!@#$%^&*()-_=+

\|[{}];:'",<.>/? 和空格，并且不能以-开头。

响应参数

无

请求示例

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/password { "new_password" : "********"

}

响应示例

无

状态码

状态码描述

204 重置密码成功。

错误码

5.2.2 重置 Manager 密码

功能介绍

重置Manager密码。

(44)

调试

URI

PUT /v2/{project_id}/instances/{instance_id}/kafka-manager-password

表5-22 路径参数

请求参数

new_passwor

d 否 String 8-32个字符。至少包含以下字

符中的3种：

● 大写字母

● 小写字母

● 数字

● 特殊字符`~!@#$%^&*()-_=+

\|[{}];:'",<.>/? 和空格，并且不能以-开头。

响应参数

无

请求示例

PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/kafka-manager-password { "new_password" : "********"

}

响应示例

无

(45)

状态码

状态码描述

204 重置密码成功。

错误码

5.2.3 重启 Manager

功能介绍

重启Manager。

调试

URI

PUT /v2/{project_id}/instances/{instance_id}/restart-kafka-manager

表5-24 路径参数

请求参数

无

响应参数

状态码： 200

result String 执行结果。

(46)

请求示例

重启Manager。

PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/restart-kafka-manager

响应示例

状态码： 200 重启Manager成功。

{ "result" : "success",

"instance_id" : "605cd78c-92dc-4335-8bae-43677f31fd6c"

}

状态码

状态码描述

200 重启Manager成功。

错误码

5.2.4 开启或关闭实例自动创建 topic 功能

功能介绍

开启或关闭实例自动创建topic功能。

调试

URI

POST /v2/{project_id}/instances/{instance_id}/autotopic

表5-26 路径参数

(47)

请求参数

enable_auto_t

opic 是 Boolean 是否开启自动创建topic功能。

响应参数

无

请求示例

开启实例自动创建topic功能。

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/autotopic { "enable_auto_topic" : true

}

响应示例

无

状态码

状态码描述

200 开启或关闭成功。

错误码

5.2.5 修改实例跨 VPC 访问的内网 IP

功能介绍

修改实例跨VPC访问的内网IP。

调试

URI

POST /v2/{project_id}/instances/{instance_id}/crossvpc/modify

(48)

表5-28 路径参数

请求参数

advertised_ip_

contents 是 Map<String,St

ring> 用户自定义的

advertised_ip_contents键值对。

键是listeners IP。

值是advertised.listeners IP，或者域名。

说明IP修改未修改项也需填上。

响应参数

状态码： 200

success Boolean 修改跨VPC访问结果。

results Array of

results

objects

修改broker跨VPC访问的结果列表。

表5-31 results

advertised_ip String advertised.listeners IP/域名。

success Boolean 修改broker跨VPC访问的状态。

ip String listeners IP。

(49)

请求示例

修改实例跨VPC访问的内网IP。

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/crossvpc/modify { "advertised_ip_contents" : {

"192.168.245.246" : "192.168.245.247", "192.168.197.36" : "192.168.197.38", "192.168.190.11" : "192.168.190.11"

}}

响应示例

状态码： 200

修改实例跨VPC访问的内网IP成功。

{ "success" : true, "results" : [ {

"advertised_ip" : "192.168.197.36", "success" : true,

"ip" : "192.168.197.36"

}, {

"ip" : "192.168.190.11"

}, {

"ip" : "192.168.245.246"

} ] }

状态码

状态码描述

200 修改实例跨VPC访问的内网IP成功。

错误码

5.2.6 查询 Kafka 集群元数据信息

功能介绍

查询Kafka集群元数据信息。

Kafka实例创建Topic_分布式消息服务Kafka版_API参考_历史API_API V1_实例管理类接口_华为云

API 参考

目 录

1 使用前必读... 1

2 API 概览... 3

3 如何调用 API...4

4 快速入门...10

5 API V2（推荐）... 12

6 权限策略和授权项...142

7 历史 API... 147

8 附录... 218

A 修订记录... 241

1 使用前必读

1.1 概述

1.2 调用说明

1.3 终端节点

1.4 约束与限制

1.5 基本概念

2 API 概览

3 如何调用 API

3.1 构造请求

bbs.huaweicloud.com/videos/102987。

请求 URI

请求方法

请求消息头

请求消息体

username

domainname

********

xxxxxxxxxxxxxxxxxx

3.2 认证鉴权

Token 认证

bbs.huaweicloud.com/videos/101333。

AK/SK 认证

3.3 返回结果

状态码

响应消息头

响应消息体（可选）

4 快速入门

场景描述

前提条件

创建 Kafka 实例

5 API V2（推荐）

5.1 生命周期管理

5.1.1 创建实例（按需）

功能介绍

调试

URI

请求参数

TagEntity

响应参数

请求示例

响应示例

状态码

错误码

5.1.2 查询所有实例列表

功能介绍

调试

URI

请求参数

响应参数

ShowInstanc eResp objects

TagEntity

请求示例

响应示例

状态码

错误码

5.1.3 查询指定实例

功能介绍

调试

URI

请求参数

响应参数

TagEntity

请求示例

响应示例

状态码

错误码

5.1.4 删除指定的实例

功能介绍

目录

1 ^{使用前必读}

2 ^{API 概览}

3 ^{如何调用 API}

4 ^快速入门