删除用户 该接口用于删除集群中的用户。 使用该接口时集群需要开启SASL身份认证。 集群处于服务中状态(ACTIVE)。 请求结构 DELETE / v { version } / clusters / { clusterId } / users / { username } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authoriza
释放集群 该接口用于释放集群 针对释放集群白名单中的用户。 请求结构 DELETE / v { version } / clusters / { clusterId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数
创建权限 该接口用于在集群中创建权限信息。 使用该接口时集群需要开启权限管理。 集群处于服务中状态(ACTIVE)。 请求结构 POST / v { version } / clusters / { clusterId } / acls HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization
停止集群 该接口用于停止集群。 请求结构 PUT / v { version } / clusters / { clusterId } / stop HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是否
删除主题 该接口用于删除集群中的主题(topic)。 集群处于服务中状态(ACTIVE)。 请求结构 DELETE / v { version } / clusters / { clusterId } / topics / { topicName } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : author
变更主题 该接口用于变更集群中指定主题(topic)的配置信息。 集群处于服务中状态(ACTIVE)。 请求结构 PUT / v { version } / clusters / { clusterId } / topics / { topicName } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : aut
启动集群 该接口用于启动集群。 请求结构 PUT / v { version } / clusters / { clusterId } / start HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是
暂停任务 该接口用于暂停集群中已经启动的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 只有任务状态为RUNNING(执行中)的情况下才能够暂停任务。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / suspend HTTP / 1.1 Host : kafka -
服务域名 Kafka API的服务域名为: Region Endpoint Protocol 北京 http://kafka-api.bj.baidubce.com/v1 HTTP and HTTPS 广州 http://kafka-api.gz.baidubce.com/v1 HTTP and HTTPS 苏州 http://kafka-api.su.baidubce.com/v1 HTTP a
取消任务 该接口用于取消集群中的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 目前只有当主题调整任务设置为自定义执行时间,并且任务没有开始执行才能够取消任务。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / cancel HTTP / 1.1 Host : kaf