检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
broker_address String broker地址 join_time Long 加入时间 请求示例 查询Topic的当前生产者列表 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers
响应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
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实例，通过以下步骤查询消费进度。 （可选）修改客户端配置文件。 在Kafka控制台的“基本信息 > 连接信息”中查看Kafka安全协议，两种安全协议对应的配置文件设置有所不同，请根据实际情况配置。 SASL_PLAINTEXT：如果已经设置了用户名和密码，请跳过此步骤，执行2
该副本当前日志大小。单位：Byte。 lag Long 该副本当前落后hw的消息数。 请求示例 查询指定Topic的详细信息。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/topics/{topic}
message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置（LEO）。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}
参数类型 描述 result Boolean 报告删除结果 id String 报告ID 请求示例 批量删除消息积压诊断报告。 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
broker注册时间，为unix时间戳格式。 is_health Boolean Kafka实例节点的连通性是否正常。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/cluster
log_end_offset String 消息偏移量。 lag String 积压的消息数。 请求示例 查询指定的转储任务详情。 GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id}
响应Body参数 参数 参数类型 描述 job_id String 创建流控配置的任务ID 请求示例 创建用户/客户端流控配置。 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
响应Body参数 参数 参数类型 描述 job_id String 修改流控配置的任务ID 请求示例 修改用户/客户端流控配置。 PUT https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
partitions objects 分区信息。 表9 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v1.0/{project_id}/instances/{instance_id}/ceshierarchy
error_msg String 错误描述。 请求示例 设置用户权限，为root用户授予发布和订阅topic-test的权限。 POST https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/accesspolicy
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
