检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
: = + - @ 响应参数 无 请求示例 创建实例标签，标签名为key1、key2，值为value1、value2。 POST https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags/action { "action"
topic_partition String 分区。 percentage Double 磁盘使用量的占比。 请求示例 查询Topic的磁盘存储情况 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/diskusage
消息内容 property_list Array of objects topic的分区信息等 请求示例 Kafka控制台发送消息 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages/action
for both the inbound and outbound directions. 安全组规则不符合要求，请确保安全组规则中同时包含协议为“ANY”的出方向和入方向规则。 请检查安全组规则 400 DMS.00400049 The availability zone does
String 每个Broker的最大TPS。 product_alias String product_id的别名。 请求示例 GET https://{endpoint}/v2/kafka/products 响应示例 状态码：200 查询产品规格列表成功。 { "engine"
objects 分区信息。 表11 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/ces-hierarchy 响应示例
修改Topic分区的副本分布位置，分区1的副本分布在broker 1和broker 2，Leader副本在broker 1。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
已开启密文接入的Kafka实例，通过以下步骤创建Topic。 （可选）修改客户端配置文件。 在Kafka控制台的“基本信息 > 连接信息”中查看Kafka安全协议，两种安全协议对应的配置文件设置有所不同，具体如下。 SASL_PLAINTEXT：如果已经设置了用户名和密码，请跳过此步骤，执行2。否则在K
表1 参数说明 参数 类型 必选 说明 engine String 是 消息引擎的类型。 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/products?engine={engine} 响应消息 响应参数 Hourly或者Monthly的参数说明见表3。
参数 参数类型 描述 name String topic名称。 请求示例 创建一个Topic，Topic名称为test01。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "id"
每个Broker的最大TPS。 product_alias String product_id的别名。 请求示例 查询实例的扩容规格列表。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/extend
参数类型 描述 task_id String 任务ID。 请求示例 创建一个转储任务，转储topic-test中的数据到OBS。 POST https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks {
-1和broker-2上，不同步复制，不同步落盘，消息时间类型为LogAppendTime，最大批处理大小10485760。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "topics"
unavailable_zones Array of strings IO已售罄的不可用区列表。 volume_type String 磁盘类型。 请求示例 GET https://{endpoint}/v2/products?engine=kafka 响应示例 状态码： 200 查询产品规格列表成功。 {
面下载Java Development Kit 1.8.111及以上版本。 下载Kafka 3.3.1版本的二进制软件包。 wget https://archive.apache.org/dist/kafka/3.3.1/kafka_2.12-3.3.1.tgz 解压二进制软件包。
reassignment_time Integer 预估时间，单位为秒（当执行预估时间任务时仅返回reassignment_time）。 请求示例 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/reassign
e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId());
职能定义权限的粗粒度授权机制。策略以API接口为粒度进行权限拆分，授权更加精细，可以精确到某个操作、资源和条件，能够满足企业对权限最小化的安全管控要求。 DMS for Kafka系统策略说明请参考权限管理。 如果您要允许或是禁止某个接口的操作权限，请使用策略。 账号具备所有接口
e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId());
e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId());
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
