检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume 响应示例 无 SDK代码示例 SDK代码示例如下。
请求示例 GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码: 200 查询项目标签成功。
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset { "topic" : "test", "partition
DELETE https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id} 响应示例 无 SDK代码示例 SDK代码示例如下。
请求示例 GET https://{endpoint}/v2/instances/maintain-windows 响应示例 状态码: 200 查询成功。
查看Kafka实例后台任务 对实例的一些操作,如表1所示,会启动一个后台任务,您可以在后台任务页,查看该操作的状态等信息,同时可通过删除操作,清理任务信息。 表1 后台任务列表 任务名 说明 创建实例 创建一个Kafka实例。 重启实例 重启Kafka实例。 Kafka配置参数修改
POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/group { "group_name" : "test" } 响应示例 状态码: 200 创建成功。
请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/coordinators 响应示例 状态码: 200 查询Kafka实例的协调器信息成功。
: = + - @ 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags 响应示例 状态码: 200 查询实例标签成功。
PUT https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks { "sink_max_tasks" : 9 } 响应示例 无 SDK代码示例 SDK代码示例如下。
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector { "specification" : "100MB", "node_cnt" : 2, "spec_code" : "
POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/groups/{group}/reset-message-offset { "topic" : "test", "partition
请求示例 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/delete-connector 响应示例 状态码: 200 提交关闭Smart Connect任务成功。
GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks 响应示例 状态码: 200 查询转储任务列表成功。
请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/connector/tasks/{task_id}/restart 响应示例 无 SDK代码示例 SDK代码示例如下
POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/autotopic { "enable_auto_topic" : true } 响应示例 无 SDK代码示例 SDK代码示例如下。
请求示例 GET https://{endpoint}/v2/available-zones 响应示例 状态码: 200 查询可用区信息成功。 查询实例成功返回示例如下。
PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/kafka-manager-password { "new_password" : "********" } 响应示例 无 SDK代码示例 SDK代码示例如下
PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/restart-kafka-manager 响应示例 状态码: 200 重启Manager成功。
GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/users 响应示例 状态码: 200 查询成功。