查询任务列表 该接口用于查询集群中的任务列表。 请求结构 GET / v { version } / clusters / { clusterId } / jobs HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数
查询权限列表 该接口用于查询集群的权限列表。 使用该接口时集群需要开启权限管理。 请求结构 GET / v { version } / clusters / { clusterId } / acls HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外
删除集群配置 该接口用于删除集群配置。 请求结构 DELETE / v { version } / configs / { configId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是否必须
查询操作详情 该接口用于查询集群中任务某个操作的详细信息。 请求结构 GET / v { version } / clusters / { clusterId } / jobs / { jobId } / operations / { operationId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization :
变更公网带宽 该接口用于变更集群公网带宽。 请求结构 PUT / v { version } / clusters / { clusterId } / eip - bandwidths / resize HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头
查询集群列表 该接口用于查询用户在该区域中所有使用中的集群列表信息。 请求结构 GET / v { version } / clusters HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是否必须 参
磁盘水位处理 概述 当集群时开启了磁盘水位处理,集群会根据所选择的磁盘阈值策略进行自动调整。 自动删除 创建集群或者变更集群时,开启磁盘水位处理后磁盘阈值策略可以选择 自动删除 。 当集群节点中的磁盘使用率达到设定的阈值时,集群会根据所设置的参数开始自动清理日志,处理步骤如下: 计算当前节点中磁盘清理到所设置的磁盘容量阈值需要删除的数据量。 获取当前节点中磁盘上各个topic partition实
查询消费组列表 该接口用于查询集群中的消费组列表信息。 请求结构 GET / v { version } / clusters / { clusterId } / consumer - groups HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外
查询主题详情 该接口用于查询集群中指定主题(topic)的详细信息。 请求结构 GET / v { version } / clusters / { clusterId } / topics / { topicName } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string
任务类型介绍 概述 在集群中进行的变更、重启等操作会在任务管理中产生一条任务记录。目前集群中的任务类型分为: 开启公网:当用户开启公网时,会产生一条开启公网的任务记录。 关闭公网:当用户关闭公网时,会产生一条关闭公网的任务记录。 变更公网带宽:当用户调整公网的带宽大小时,会产生一条变更公网带宽的记录。 增加节点数量:当用户通过变更操作新增集群的节点时,会产生一条增加节点数量的任务记录。 扩容节点磁