检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置类型：static/dynamic。 value String 配置当前值。 value_type String 值类型。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs 响应示例 状态码：200
partitions objects 分区信息。 表9 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v1.0/{project_id}/instances/{instance_id}/ceshierarchy
容。 分布式消息服务Kafka版提供了REST（Representational State Transfer）风格API，支持您通过HTTPS请求调用，调用方法请参见如何调用API。 终端节点 终端节点（Endpoint）即调用API的请求地址，不同服务不同区域的终端节点不同，
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
error_msg String 错误描述。 请求示例 设置用户权限，为root用户授予发布和订阅topic-test的权限。 POST https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/accesspolicy
: = + - @ 响应参数 无 请求示例 创建实例标签，标签名为key1、key2，值为value1、value2。 POST https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags/action { "action"
Kafka客户端使用建议 consumer使用建议 consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 通常不建议对每条消息都进行commit，如果对
log_end_offset String 消息偏移量。 lag String 积压的消息数。 请求示例 查询指定的转储任务详情。 GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id}
响应Body参数 参数 参数类型 描述 job_id String 创建流控配置的任务ID 请求示例 创建用户/客户端流控配置。 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
响应Body参数 参数 参数类型 描述 job_id String 修改流控配置的任务ID 请求示例 修改用户/客户端流控配置。 PUT https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
修改Topic分区的副本分布位置，分区1的副本分布在broker 1和broker 2，Leader副本在broker 1。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
objects 分区信息。 表11 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/ces-hierarchy 响应示例
参数 参数类型 描述 name String topic名称。 请求示例 创建一个Topic，Topic名称为test01。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "id"
-1和broker-2上，不同步复制，不同步落盘，消息时间类型为LogAppendTime，最大批处理大小10485760。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "topics"
参数类型 描述 task_id String 任务ID。 请求示例 创建一个转储任务，转储topic-test中的数据到OBS。 POST https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks {
String 每个Broker的最大TPS。 product_alias String product_id的别名。 请求示例 GET https://{endpoint}/v2/kafka/products 响应示例 状态码：200 查询产品规格列表成功。 { "engine"
Connect任务名_source_0”和“Smart Connect任务名_source_1”。 如果Topic中的消息在进行下一次数据同步前，已经全部老化，此时实际是没有待同步的Kafka数据，但是Kafka数据同步监控指标使用的是包含老化数据的offset值，“待同步Kafka数据量”会显示老化的消息数。
每个Broker的最大TPS。 product_alias String product_id的别名。 请求示例 查询实例的扩容规格列表。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/extend
面下载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 解压二进制软件包。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
