检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例id 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/management
实例ID。 task_id 是 String Smart Connector任务ID。 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 无 请求示例 删除指定的实例。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id} 响应示例 无 SDK代码示例
实例ID。 task_id 是 String 任务ID。 请求参数 无 响应参数 无 请求示例 删除后台任务管理中的指定记录。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks/{task_id}
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
TagMultyValueEntity 参数 参数类型 描述 key String 标签键。 values Array of strings 标签值。 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码： 200 查询项目标签成功。 {
p。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 重置的消费进度到指定偏移量。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/gro
8.0_151 export PATH=$JAVA_HOME/bin:$PATH 执行source .bash_profile命令使修改生效。 命令行模式连接实例 以下操作命令以Linux系统为例进行说明： 解压Kafka命令行工具。 进入文件压缩包所在目录，然后执行以下命令解压文件。
是否为默认可用区。 remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 GET https://{endpoint}/v2/available-zones 响应示例 状态码： 200 查询可用区信息成功。 查询实例成功返回示例如下。
@#$%^&*()-_=+\|[{}];:'",<.>/? 和空格，并且不能以-开头。 响应参数 无 请求示例 重置Kafka Manager的密码。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/kafka-manager-password
result String 执行结果。 instance_id String 实例ID。 请求示例 重启Kafka Manager。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/restart-kafka-manager
default_app Boolean 是否为默认应用。 created_time Long 创建时间。 请求示例 查询用户列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/users 响应示例 状态码：
Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
Integer 最新消息位置。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
error_code String 错误码。 error_msg String 错误描述。 请求示例 创建一个消费组，消费组名为test。 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/group {
Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/coordinators
长度为0~255个字符（中文也可以输入255个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @ 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags 响应示例 状态码： 200
message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置（LEO）。 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}
100MB 300MB 600MB 1200MB node_cnt 否 String Smart Connect节点数量。不能小于2个。 如果不填，默认是2个。 spec_code 否 String 转储节点规格编码。仅老规格实例需要填写。 响应参数 状态码： 200 表3 响应Body参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
