重置消费组位点 该接口用于重置集群中指定消费组的位点数据。 集群处于服务中状态(ACTIVE)。 请求结构 POST / v { version } / clusters / { clusterId } / consumer - groups / { groupName } / offsets HTTP / 1.1 Host : kafka - api . bd . baidubce . com
变更集群配置 该接口用于变更集群配置。 请求结构 PUT / v { version } / clusters / { clusterId } / update - kafka - config HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无
查询任务列表 该接口用于查询集群中的任务列表。 请求结构 GET / v { version } / clusters / { clusterId } / jobs 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
删除集群配置 该接口用于删除集群配置。 请求结构 DELETE / v { version } / configs / { configId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是否必须
查询集群详情 该接口用于查询指定集群的详细信息。 请求结构 GET / v { version } / clusters / { clusterId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型
增加节点数量 该接口用于增加集群节点数量。 请求结构 PUT / v { version } / clusters / { clusterId } / increase - broker - count HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头
变更公网带宽 该接口用于变更集群公网带宽。 请求结构 PUT / v { version } / clusters / { clusterId } / eip - bandwidths / resize HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头