检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置类型：dynamic/static value String 配置值 value_type String 配置值类型 请求示例 查询Topic列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics?offset=0&limit=10
配置类型：static/dynamic。 value String 配置当前值。 value_type String 值类型。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs 响应示例 状态码：
: = + - @ 响应参数 无 请求示例 创建实例标签，标签名为key1、key2，值为value1、value2。 POST https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags/action { "action"
error_msg String 错误描述。 请求示例 设置用户权限，为root用户授予发布和订阅topic-test的权限。 POST https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/accesspolicy
修改Topic分区的副本分布位置，分区1的副本分布在broker 1和broker 2，Leader副本在broker 1。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
响应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
objects 分区信息。 表11 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/ces-hierarchy 响应示例
Kafka客户端使用建议 consumer使用建议 consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 通常不建议对每条消息都进行commit，如果对
参数 参数类型 描述 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"
String 每个Broker的最大TPS。 product_alias String product_id的别名。 请求示例 GET https://{endpoint}/v2/kafka/products 响应示例 状态码： 200 查询产品规格列表成功。 查询产品规格列表成功。
表1 参数说明 参数 类型 必选 说明 engine String 是 消息引擎的类型。 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/products?engine={engine} 响应消息 响应参数 Hourly或者Monthly的参数说明见表3。
图中③区域表示该队列的消费组列表。单击消费组名称可进入该消费组的详情页。 图中④区域表示队列的配置信息。详情参考Kafka队列官方配置文档(https://kafka.apache.org/documentation/#topicconfigs)。 图中⑤区域表示队列监控数据统计。 图
每个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 解压二进制软件包。
reassignment_time Integer 预估时间，单位为秒（当执行预估时间任务时仅返回reassignment_time）。 请求示例 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/reassign
Kafka集群实例 Kafka集群实例规格 Kafka集群实例由三个及以上代理组成，兼容开源Kafka 1.1.0、2.7和3.x。 TPS（Transaction per second），在Kafka场景中，指每秒能写入到Kafka实例的最大消息数量。下表中TPS性能，是指以1
e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId());
错误码 当您调用API时，如果遇到“APIGW”开头的错误码，请参见API网关错误码进行处理。 更多服务错误码请参见API错误中心。 状态码 错误码 错误信息 描述 处理措施 400 DMS.00400002 The project ID format is invalid. Project-ID的格式无效。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
