检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
错误码。 error_msg String 错误描述。 请求示例 对消费组group-1所订阅的topic-1进行消息积压诊断预检查 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/diagnosis-check
Integer 消息大小，单位字节。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 查询消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups?offest=
broker_address String broker地址 join_time Long 加入时间 请求示例 查询Topic的当前生产者列表 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers
权限类型。 all：拥有发布、订阅权限; pub：拥有发布权限; sub：拥有订阅权限。 请求示例 查询Topic的用户权限。 GET https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy
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
accumulated_partitions Integer 该次诊断任务发现的存在消息堆积的分区数 请求示例 查询消息积压诊断报告列表。 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
static_config Integer 本次修改静态配置参数个数。 请求示例 修改实例的连接空闲超时和日志删除的时间阈值。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs { "kafka_configs"
Integer 诊断结论ID params Map<String,String> 诊断结论参数列表 请求示例 查询诊断报告详情。 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-
user_name 否 String 用户名。 user_desc 否 String 用户描述。 响应参数 无 请求示例 修改用户参数。 PUT https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/users/{user_name}
Integer 消息大小，单位字节。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
修改broker跨VPC访问的状态。 ip String listeners IP。 请求示例 修改实例跨VPC访问的内网IP。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/crossvpc/modify
参数类型 描述 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
message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置（LEO）。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}
该副本当前日志大小。单位：Byte。 lag Long 该副本当前落后hw的消息数。 请求示例 查询指定Topic的详细信息。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/topics/{topic}
容。 分布式消息服务Kafka版提供了REST（Representational State Transfer）风格API，支持您通过HTTPS请求调用，调用方法请参见如何调用API。 终端节点 终端节点（Endpoint）即调用API的请求地址，不同服务不同区域的终端节点不同，
partitions objects 分区信息。 表9 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v1.0/{project_id}/instances/{instance_id}/ceshierarchy
: = + - @ 响应参数 无 请求示例 创建实例标签，标签名为key1、key2，值为value1、value2。 POST https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags/action { "action"
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
