检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
topic_partition String 分区。 percentage Double 磁盘使用量的占比。 请求示例 查询Topic的磁盘存储情况 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/diskusage
small除外）使用的独占资源，性能更优，性价比更高。 新规格支持最新的功能，例如：分区平衡、动态开启SSL、重平衡日志可观测等。 新规格支持规格灵活变更，例如：Broker规格的扩缩容。 新规格的磁盘大小选择更加灵活，磁盘大小不与实例规格进行绑定，仅与Broker数量相关。 新规格选择粒度
实例ID。 task_id 是 String Smart Connector任务ID。 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}
在“重启实例”对话框中，单击“是”，完成重启Kafka实例。 重启Kafka实例大约需要3到15分钟。Kafka实例重启成功后，实例状态切换为“运行中”。 重启Kafka实例只会重启实例进程，不会重启实例所在虚拟机。 父主题： 管理实例
String 实例ID。 task_id 是 String Smart Connect任务ID。 请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause
String 实例ID。 task_id 是 String Smart Connect任务ID。 请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume
Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/coordinators
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 无 请求示例 删除指定的实例。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id} 响应示例 无 SDK代码示例
TagMultyValueEntity 参数 参数类型 描述 key String 标签键。 values Array of strings 标签值。 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码： 200 查询项目标签成功。 {
估业务影响，建议您在业务低峰期扩容/缩容。 扩容/缩容代理规格的过程中，节点滚动重启造成分区Leader切换，会发生秒级连接闪断，在用户网络环境稳定的前提下，Leader切换时长一般为1分钟以内。多副本的Topic需要在生产客户端配置重试机制。 若集群实例已创建的分区数总和大于待
启动已暂停的Smart Connect任务 启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务 规格变更管理 包括： 实例扩容 查询实例的扩容规格列表 主题管理 包括： Kafka生产消息 Kafka实例创建Topic Kafka实例查询Topic
-1和broker-2上，不同步复制，不同步落盘，消息时间类型为LogAppendTime，最大批处理大小10485760。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "topics"
长度为0~255个字符（中文也可以输入255个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @ 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags 响应示例 状态码： 200
group_name 否 String 消费组名称 group_desc 否 String 消费组描述 响应参数 无 请求示例 PUT https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}
实例ID。 task_id 是 String 任务ID。 请求参数 无 响应参数 无 请求示例 删除后台任务管理中的指定记录。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks/{task_id}
p。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 重置的消费进度到指定偏移量。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/gro
p。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 重置的消费进度到指定偏移量。 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/groups/{
创建Kafka实例 当前页面API为历史版本API，未来可能停止维护。请使用创建实例。 功能介绍 创建实例，该接口创建的实例为按需计费的方式。 URI POST /v1.0/{project_id}/instances 参数说明见表1。 表1 参数说明 参数 类型 必选 说明 project_id
message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置（LEO）。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}
Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 查询消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups?offest=
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
