检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 topic 是 String Topic名称。 Topic名称必须以字母开头且只支持大小写字母、中横线、下划线以及数字。 表2 Query参数 参数 是否必选 参数类型 描述 start_time
soldOut Boolean 是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。 true:还有资源。
实例ID。 user_name 是 String 用户名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 new_password 否 String 用户新密码。 重置用户密码时,为必选参数; 不能与名称或倒序的名称相同。 复杂度要求: 输入长度为8到32位的字符串。
是 String 实例ID 表2 Query参数 参数 是否必选 参数类型 描述 group 是 String 消费组名称 topic 是 String 主题名称 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 [数组元素] Array of
项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 topic 是 String Topic名称。 Topic名称必须以字母开头且只支持大小写字母、中横线、下划线以及数字。 partition 是 Integer 分区编号。 表2 Query参数
instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 topic 是 String Topic名称。 Topic名称必须以字母开头且只支持大小写字母、中横线、下划线以及数字。 asc 否 Boolean 是否按照时间排序。 start_time 否
instance_id 是 String 实例ID。 topic 是 String Topic名称。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 topic String topic名称。 partitions Array of partitions objects
e动作为止。 问题规避 建议用户根据业务区分不同消费组使用,降低单消费者阻塞导致的影响访问。 max.poll.interval.ms用于设置消费组请求消费消息的最大时间间隔,如果消费者在超时前没有发起下一次消费请求,服务端会触发rebalance。调大max.poll.interval
String 实例ID。 user_name 是 String 用户名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 new_password 否 String 用户新密码。 不能与名称或倒序的名称相同。 复杂度要求: 输入长度为8到32位的字符串。 必须包含如下四种字符中的三种组合:
是否包含topic信息。默认是false。 请求参数 无 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 task_name String 转储任务名称。 destination_type String 转储任务类型。 create_time Long 转储任务创建时间戳。 status String
查询Kafka集群元数据信息 功能介绍 查询Kafka集群元数据信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/cluster 表1 路径参数 参数 是否必选 参数类型
vpc_name String VPC的名称。 created_at String 完成创建时间。 格式为时间戳,指从格林威治时间 1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。 subnet_name String 子网名称。 subnet_cidr String
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 group_name 是 String 消费组名称 topic_name 是 String topic名称 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 report_id String 诊断报告ID。
主题管理,包括Topic管理接口对应的授权项,如创建Topic、查询Topic、修改Topic等接口。 用户管理,包括用户管理接口对应的授权项,如创建用户、查询用户列表、设置用户权限等接口。 消息查询,包括消息查询接口对应的授权项,如查询消息接口。 后台任务管理,包括实例的后台任务管理接口对应的授权项,如查询实
String 实例ID。 topic_name 是 String Topic名称。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 name String topic名称。 topic_type Integer topic类型。 policies
ter”,即可查找到该资源。 如果没有搜索到Kafka实例,可能是因为该实例已被删除,当前存放在回收站中。在回收站页面,单击Kafka实例名称,进入实例详情页,确认2中复制的资源ID是否为磁盘存储ID,如果是,此资源即为计费资源。如果不是,查看回收站中其他Kafka实例的磁盘存储ID,直到找到计费资源为止。
{ "project": { "name": "xxxxxxxx" //项目名称 } } } } 获取Token后,再调用其他接口时,您需要在请求消息头中添加“X-Aut
end_time String 诊断任务结束时间 group_name String 该次诊断任务诊断的消费组名称 topic_name String 该次诊断任务诊断的topic名称 accumulated_partitions Integer 该次诊断任务发现的存在消息堆积的分区数 请求示例
诊断维度列表 表3 KafkaMessageDiagnosisDimensionEntity 参数 参数类型 描述 name String 诊断维度名称 abnormal_num Integer 该诊断维度下,异常的诊断项总数 failed_num Integer 该诊断维度下,诊断失败的诊断项总和
objects Broker列表。 表4 DiskusageEntity 参数 参数类型 描述 broker_name String Broker名称。 data_disk_size String 磁盘容量。 data_disk_use String 已使用的磁盘容量。 data_disk_free