检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
参数说明见表2。 表2 参数说明 参数 类型 是否必选 说明 topics Array 是 待删除的topic列表 请求示例 POST https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id}/topics/delete
Integer 租户最大可以创建的实例个数，或者每个实例最大可以创建的标签个数。 used Integer 已创建的实例个数。 请求示例 GET https://{endpoint}/v1.0/{project_id}/quotas/dms 响应示例 状态码： 200 查询成功。 { "quotas"
消费者Id host String host名称 client_id String 客户端Id 请求示例 查询消费组消息位点 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/group
Kafka客户端使用建议 consumer使用建议 consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 通常不建议对每条消息都进行commit，如果对
enable Boolean 开启动作或者关闭动作。 请求示例 实例第一次开启内网SASL_SSL，需要传入用户名及密码。 POST https://{endpoint}/v2/{project_id}/{engine}/instances/{instance_id}/plain-ssl-switch
请参考查询实例返回的数据。 task_id 是 String 转储任务ID。 请求参数 无 响应参数 无 请求示例 删除指定的转储任务。 DELETE https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id}
result String 执行结果。 instance_id String 实例ID。 请求示例 重启Kafka Manager。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/restart-kafka-manager
@#$%^&*()-_=+\|[{}];:'",<.>/? 和空格，并且不能以-开头。 响应参数 无 请求示例 重置Kafka Manager的密码。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/kafka-manager-password
错误码。 error_msg String 错误描述。 请求示例 对消费组group-1所订阅的topic-1进行消息积压诊断预检查 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/diagnosis-check
String 删除失败的消费组ID。 error_message String 删除失败的原因。 请求示例 批量删除消费组。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/batch-delete
String 任务状态。 created_at String 启动时间。 updated_at String 结束时间。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks/{task_id}
message_count Long 分区消息数 last_update_time Long 最近更新时间 请求示例 查询topic的分区列表 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/partitions
特殊字符包括（`~!@#$%^&*()-_=+|[{}]:'",<.>/?）和空格，并且不能以-开头 响应参数 无 请求示例 重置用户密码。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/users/{user_name}
static_config Integer 本次修改静态配置参数个数。 请求示例 修改实例的连接空闲超时和日志删除的时间阈值。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs { "kafka_configs"
accumulated_partitions Integer 该次诊断任务发现的存在消息堆积的分区数 请求示例 查询消息积压诊断报告列表。 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
Integer 诊断结论ID params Map<String,String> 诊断结论参数列表 请求示例 查询诊断报告详情。 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-
String 错误码。 error_msg String 错误描述。 请求示例 创建一个用户，用户名为test，密码为Cxxx3。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/users { "user_name"
String 任务状态。 created_at String 启动时间。 updated_at String 结束时间。 请求示例 'GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks?start={s
user_name 否 String 用户名。 user_desc 否 String 用户描述。 响应参数 无 请求示例 修改用户参数。 PUT https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/users/{user_name}
容。 分布式消息服务Kafka版提供了REST（Representational State Transfer）风格API，支持您通过HTTPS请求调用，调用方法请参见如何调用API。 终端节点 终端节点（Endpoint）即调用API的请求地址，不同服务不同区域的终端节点不同，
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
