检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
GroupMemberEntity 参数 参数类型 描述 member_id String 成员Id client_id String 客户端Id 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/members
project_id String 是 项目ID。 instance_id String 是 实例ID 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id}/topics 响应消息
实例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 查询项目标签成功。 { "tags"
p。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 重置的消费进度到指定偏移量。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/gro
message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置(LEO)。 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}
状态码:200 表2 响应Body参数 参数 参数类型 描述 job_id String 返回异步执行删除任务的job id。 请求示例 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/delete-connector
String 转储任务状态。 topics String 返回任务转存的topics列表或者正则表达式。 请求示例 查询转储任务列表。 GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks 响应示例
@#$%^&*()-_=+\|[{}];:'",<.>/? 和空格,并且不能以-开头。 响应参数 无 请求示例 重置密码。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/password { "new_password"
String 实例ID。 task_id 是 String Smart Connect任务ID。 请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/connecto
enable_auto_topic 是 Boolean 是否开启自动创建topic功能。 响应参数 无 请求示例 开启实例自动创建topic功能。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/autotopic {
group_name 否 String 消费组名称 group_desc 否 String 消费组描述 响应参数 无 请求示例 PUT https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}
描述 id String Topic名称。 success Boolean 是否删除成功。 请求示例 批量删除Topic。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/delete
report_id String 诊断报告ID。 请求示例 创建消费组group-test,主题topic-test的消息积压诊断任务 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
Integer 消息大小,单位字节。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
响应Body参数 参数 参数类型 描述 job_id String 删除流控配置的任务ID 请求示例 删除用户/客户端流控配置。 DELETE https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
配置类型: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 响应示例 状态码:200