接口说明

Topic相关接口

创建Topic

描述

本接口用于创建一个Kafka topic。

请求

  • 请求结构

    POST /v{version}/topic?clientToken={clientToken} HTTP/1.1
    
    {
        "topicName": "topicName",
        "partitionCount": partitionCount,
    }
    
  • 请求头域

    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
clientToken String Query参数 幂等性Token,是一个长度不超过64位的ASCII字符串,详见链接
topicCreateParameters TopicCreateParameters RequestBody参数 创建topic参数

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
topicName String topic名称

错误码

错误码 HTTP状态码 中文解释
TopicAlreadyExist 409 topic名已经存在
TopicLimitExceeded 402 topic总数超过限制,最多只能创建20个
TopicPartitionLimitExceeded 402 单个topic分区总数超过限制,每个topic最多只能创建10个分区
InvalidTopicName 400 topic名不合法,只能包含大小写英文字母,数字,下划线_,横行-,不能使用双下划线__
InvalidTopicPartitionCount 400 分区数需要大于0

示例

  • 请求示例

    POST /v1/topic?clientToken=16011728-8000-4ef4-9299-020db1424806 HTTP/1.1
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "topicName" : "demo",
        "partitionCount" : 1
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    
    {"topicName":"demo"}
    

查询topic列表

描述

查询所有topic的详细信息。

请求

  • 请求结构

    GET /v{version}/topic?marker={marker}&maxKeys={maxKeys} HTTP/1.1
    
  • 请求头域

    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
marker String Query参数 批量获取列表的查询的起始位置,是一个由系统生成的字符串
maxKeys int Query参数 每页包含的最大数量,最大数量通常不超过1000,缺省值为1000

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
marker String 标记查询的起始位置
isTruncated boolean true表示后面还有数据,false表示已经是最后一页
nextMarker String 获取下一页所需要传递的marker值,当isTruncated为false时,该域不出现
topics List\<Topic> topic信息,由 Topic 组成的集合

错误码

错误码 HTTP状态码 中文解释
InvalidMarker 400 marker不能为空,且长度应小于topic名最大长度

示例

  • 请求示例

    GET /v1/topic?marker=demo&maxKeys=10 HTTP/1.1
    authorization: bce-auth-v1/e9af9439-0c14-4b98-abae-ba14f11b25ec/2017-02-15T08:08:08Z/3600/host;x-bce-console-rpc-id;x-bce-date/69143dbee3abf6b6143c8266139645a19c192de6d25082fed3611ad2fe28b456/
    x-bce-console-rpc-id: d4d32d1f-f2cd-41a8-bfb7-fdd65cdc6ed9
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-15T08:08:08Z
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Wed, 15 Feb 2017 08:08:09 GMT
    Content-Type: application/json;charset=UTF-8
    
    {
        "marker": "demo",
        "nextMarker": "test",
        "maxKeys": 10,
        "topics": [{
        "topicName": "demo",
        "partitionCount": 3,
        "replicationFactor": 3,
        "createTime": "2017-02-15T08:08:09Z"
        }],
    "truncated": false
    }
    

查询topic详情

描述

查询单个topic的详细信息。

请求

  • 请求结构

    GET /v{version}/topic/{topicName} HTTP/1.1
    
  • 请求头域

    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
topicName String URL参数 topic名

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
topic Topic 返回的topic详情

错误码

错误码 HTTP状态码 中文解释
TopicNotFound 404 topic不存在

示例

  • 请求示例

    GET /v1/topic/demo HTTP/1.1
    authorization: bce-auth-v1/e9af9439-0c14-4b98-abae-ba14f11b25ec/2017-02-15T08:19:54Z/3600/host;x-bce-console-rpc-id;x-bce-date/6301919cc9ade759c88bfc47a7eee26b8347179f1c2fcd2808acfa4ab6d8b800
    x-bce-console-rpc-id: 89ca2463-4d0d-453d-9b7c-4e4cf52214e7
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-15T08:19:54Z
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Wed, 15 Feb 2017 08:19:55 GMT
    Content-Type: application/json;charset=UTF-8
    
    {
        "topic": {
            "topicName": "demo",
            "partitionCount": 3,
            "replicationFactor": 3,
            "createTime": "2017-02-15T08:19:55Z"
            }
    }
    

删除topic

描述

删除一个指定的topic。

请求

  • 请求结构

    DELETE /v{version}/topic/{topicName} HTTP/1.1
    
  • 请求头域

    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
topicName String URL参数 待删除topic名

返回

  • 返回头域

    除公共头域,无其它特殊头域

  • 返回参数

    无特殊返回参数

错误码

错误码 HTTP状态码 中文解释
TopicNotFound 404 topic不存在

示例

  • 请求示例

    DELETE /v1/topic/demo HTTP/1.1
    authorization: bce-auth-v1/e9af9439-0c14-4b98-abae-ba14f11b25ec/2017-02-15T08:34:26Z/3600/host;x-bce-console-rpc-id;x-bce-date/fbfec8e0ab86dfdbd2bce5d353f7cdd0bec78303a86f1ca1d939a85dae2284d6
    x-bce-console-rpc-id: 5bdd1701-cbb6-48cc-9819-a457a0475539
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-15T08:34:26Z
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Cache-Control: no-cache
    

权限管理相关接口

添加授权

描述

本接口用于给用户对某个kafka topic授权

请求

  • 请求结构

    POST /v{version}/authorization/add             HTTP/1.1
    
    {
        "topic": "topic",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
          "certificateId": "certificateId",
          "topicOperation": "ReadWrite"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
TopicAuthorizationParameters TopicAuthorizationParameters RequestBody参数 添加授权参数

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

    无特殊返回参数

错误码

错误码 HTTP状态码 中文解释
InvalidRequestException 400 请求体中某些参数为空

示例

  • 请求示例

    POST /v1/authorization/add
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "topic": "demo",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
          "certificateId": "certificateId",
          "topicOperation": "ReadWrite"
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

取消授权

描述

本接口用于针对自己的某个topic,取消对某个用户的授权

请求

  • 请求结构

    POST /v{version}/authorization/cancel             HTTP/1.1
    
    {
        "topic": "topic",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
topic String RequestBody参数 topic名称,只能包含大小写英文字母,数字,下划线_,横行-,不能使用双下划线__
accountId String RequestBody参数 用户Id
certificateSN String RequestBody参数 证书序列号

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

    无特殊返回参数

错误码

错误码 HTTP状态码 中文解释
InvalidRequestException 400 topic参数为空

示例

  • 请求示例

    POST /v1/authorization/cancel
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "topic": "demo",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

查询授权信息列表

描述

本接口用于按照不同的查询条件获取授权的topic列表

请求

  • 请求结构

    POST /v{version}/authorization/list             HTTP/1.1
    
    {
        "topicLike": "topicLike",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
          "begin":
          "limit":
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
topicLike String RequestBody参数 topic名称,只支持模糊搜索
accountId String RequestBody参数 用户Id
certificateSN String RequestBody参数 证书序列号
limit Integer RequestBody参数 查询记录数
begin Integer RequestBody参数 查询起始索引

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
begin int 查询起始索引
size int 查询记录数

topicAuthList|List\<TopicAuthorizationParameters >|由TopicAuthorization组成的集合|

错误码

示例

  • 请求示例

    POST /v1/authorization/list
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "topic": "demo",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
          "begin": 0,
          "limit": 10
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    
    {
        "begin":1,
        "size":5,
        "topicAuthList":[]  
    }
    

group对证书授权

描述

本接口用于group对证书授权

请求

  • 请求结构

    POST /v{version}/authorization/consumergroup/add     HTTP/1.1
    
    {
        "consumerGroupName": "consumerGroupName",
        "accountId": "accountId",
          "certificateId": "certificateId"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
GroupAuthorizationParameters GroupAuthorizationParameters RequestBody参数 group授权参数

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

    无特殊返回参数

错误码

示例

  • 请求示例

    POST /v1/authorization/consumergroup/add
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "topic": "demo",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

取消group对证书授权

描述

本接口用于group对证书授权

请求

  • 请求结构

    POST /v{version}/authorization/consumergroup/remove     HTTP/1.1
    
    {
        "consumerGroupName": "consumerGroupName",
        "accountId": "accountId",
          "certificateId": "certificateId"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
GroupAuthorizationParameters GroupAuthorizationParameters RequestBody参数 取消group授权参数

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

    无特殊返回参数

错误码

示例

  • 请求示例

    POST /v1/authorization/consumergroup/add
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "topic": "demo",
        "accountId": "accountId",
          "certificateSN": "certificateSN",
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

查询group对证书授权

描述

本接口用于按照consumer group查询被授权的证书

请求

  • 请求结构

    POST /v{version}/authorization/consumergroup/list?accountId={accountId}&certType={certType}&group={consumerGroupName}     HTTP/1.1
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
accountId String Query参数 用户Id
certType String Query参数 证书类型
group String Query参数 consumer group名称

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

    无特殊返回参数

错误码

示例

  • 请求示例

    POST /v1/authorization/consumergroup/list?accountId=account1&certType=privilege&group=consumerGroupName1
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    
    {
        "authorizedCertificates":[
            "certificateId": "certificateDemo",
            "description": "descriptionDemo",
            "consumerGroupOperation": "Use"      
        ]
    }
    

证书管理相关接口

查询证书列表

描述

本接口用于查询证书列表

请求

  • 请求结构

    POST /v{version}/certificate/list?marker={marker}&maxKeys={maxKeys}   
    HTTP/1.1
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
version String URL参数 API版本号
marker String Query参数 查询位置标记,批量获取列表的查询的起始位置,是一个由系统生成的字符串
maxKeys Integer Query参数 查询最大记录数,每页包含的最大数量,最大数量通常不超过1000,缺省值为1000

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
marker String 标记查询的起始位置
isTruncated boolean true表示后面还有数据,false表示已经是最后一页
nextMarker String 获取下一页所需要传递的marker值,当isTruncated为false时,该域不出现
certificates List\<certificates> certificates信息,由 certificate组成的集合

错误码

示例

  • 请求示例

    POST /v1/authorization/certificate/list?marker=marker&maxKeys=10
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

    {

    "marker": "demo",
            "nextMarker": "test",
            "isTruncated": false,
            "certificates":[],
    

    }

    获取certificate信息

    描述

本接口用于获取certificate信息

请求

  • 请求结构

    POST /v{version}/certificate/detail/{certificateId}  
    HTTP/1.1
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
certificateId String URL参数 证书Id

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
certificate certificate certificates信息

错误码

示例

  • 请求示例

    POST /v1/authorization/certificate/detail/certificateId1  
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    
      {
            "certificate":{
                "uuid": ,
                "accountId": ,
                "certificateCN": ,
                "createAt": ,
                "revokeAt": ,
                "certificate": ,
                "privateKey": ,
                "region": ,
                "description": ,
                "isPrivilege":}
    

    }

重新生成新的证书

描述

本接口用于重新生成新的证书

请求

  • 请求结构

    POST /v{version}/certificate/recreate  HTTP/1.1
    {
        "certificateSN":"certificateSN"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
certificateSN String RequestBody 证书Id

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
certificate certificate certificates信息

错误码

示例

  • 请求示例

    POST /v1/authorization/certificate/recreate
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

    {

    "certificate":{
                "uuid": ,
                "accountId": ,
                "certificateCN": ,
                "createAt": ,
                "revokeAt": ,
                "certificate": ,
                "privateKey": ,
                "region": ,
                "description": ,
                "isPrivilege":}
    

    }

创建普通证书

描述

本接口用于查询证书列表

请求

  • 请求结构

    POST /v{version}/certificate/create/ordinary  HTTP/1.1
    
    {
        "description":"",
        "authInfos":[]
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
description String RequestBody参数 证书描述
authInfos List\<authInfo> authInfos信息,由authInfo组成的集合

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
certificate certificate certificates信息

错误码

示例

  • 请求示例

    POST /v1/certificate/create/ordinary
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "description":"",
        "authInfos":[
            {
                "topic": "demo",
                "topicCluster": "KAFKA_01",
                "topicOperation":"Read"
            }
        ]
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    
        {
            "certificate":{
                "uuid": ,
                "accountId": ,
                "certificateCN": ,
                "createAt": ,
                "revokeAt": ,
                "certificate": ,
                "privateKey": ,
                "region": ,
                "description": ,
                "isPrivilege":}
    

    }

创建特权证书

描述

本接口用于创建特权证书

请求

  • 请求结构

    POST /v{version}/certificate/create/privilege  HTTP/1.1
    
    {
        "description":"description",
        "topicOperation":"Read"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
description String RequestBody参数 证书描述
topicOperation String RequestBody参数 授权,如果不指定,则没有权限

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
certificate certificate certificates信息

错误码

示例

  • 请求示例

    POST /v1/certificate/create/privilege
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "description":"description",
        "topicOperation":"Read"
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    
    {
            "certificate":{
                "uuid": ,
                "accountId": ,
                "certificateCN": ,
                "createAt": ,
                "revokeAt": ,
                "certificate": ,
                "privateKey": ,
                "region": ,
                "description": ,
                "isPrivilege":}
    

    }

    删除证书

    描述

本接口用于删除证书

请求

  • 请求结构

    POST /v{version}/certificate/delete   HTTP/1.1
    {
        "uuid":"uuidDemo"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
uuid String RequestBody 证书序列号

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

无特殊返回参数

错误码

示例

  • 请求示例

    POST /v1/certificate/delete
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "uuid": "uuidDemo"
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

更改证书备注

描述

本接口用于更改证书备注

请求

  • 请求结构

    POST /v{version}/certificate/update  HTTP/1.1
    {
           "uuid": "uuidDemo"
           "description": "descriptionDemo"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
uuid String RequestBody 证书序列号
description String RequestBody 证书描述

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
certificate certificate certificates信息

错误码

示例

  • 请求示例

    POST /v1/certificate/update
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
           "uuid": "uuidDemo"
           "description": "descriptionDemo"
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

    {

    "certificate":{
                "uuid": ,
                "accountId": ,
                "certificateCN": ,
                "createAt": ,
                "revokeAt": ,
                "certificate": ,
                "privateKey": ,
                "region": ,
                "description": ,
                "isPrivilege":}
    

    }

下载证书

描述

本接口用于下载证书

请求

  • 请求结构

    POST /v{version}/certificate/download   HTTP/1.1
    {
            "certificateSN": ""
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 是否必需 参数位置 描述
certificateSN String RequestBody 证书Id

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

返回证书文件

错误码

示例

  • 请求示例

    POST /v1/certificate/download
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
            "certificateSN": "certificateDemo"
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/octet-stream
    

下载sample样例文件

描述

本接口用于下载sample样例文件

请求

  • 请求结构

    POST /v{version}/certificate/download/sample  HTTP/1.1
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

返回sample样例文件

错误码

示例

  • 请求示例

    POST /v1/authorization/certificate/download/sample
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/octet-stream
    

集群管理接口

获取用户创建集群的权限列表

描述

本接口用于获取用户创建集群的权限列表

请求

  • 请求结构

    POST /v{version}/cluster/permission  
    HTTP/1.1
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
clusterPermissions List\<clusterPermission> clusterPermissions信息,由clusterPermission组成的集合

错误码

示例

  • 请求示例

    POST /v1/cluster/permission
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

    {

    "clusterPermissions":[{
            "accountId": "accountId",
            "cluster": "KAFKA_02",
            "isVisible":false},
            ]
    

    }

Consumer Group管理相关接口

创建ConsumerGroup

描述

本接口用于创建ConsumerGroup

请求

  • 请求结构

    POST /v{version}/consumergroups/new/create HTTP/1.1
    {
        "consumerGroupName":"consumerGroupName"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 描述
consumerGroupName String consumerGroup名称

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
consumerGroupName String consumerGroup名称

错误码

示例

  • 请求示例

    POST /v1/consumergroups/new/create
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "consumerGroupName":"consumerGroupDemo"
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

    {

    "consumerGroupName":"consumerGroupDemo"
    

    }

ConsumerGroup列表

描述

本接口用于获取ConsumerGroup列表

请求

  • 请求结构

    POST /v{version}/consumergroups/new/list?begin={begin}&limit={limit} HTTP/1.1
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 描述
begin url 检索记录开始索引
limit url 要检索的记录数

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
begin Integer 检索记录开始索引
limit Integer 要检索的记录数
consumerGroups List\<consumerGroup> consumerGroups信息,由consumerGroup组成的集合

错误码

示例

  • 请求示例

    POST /v1/consumergroups/new/list?begin=0&limit=1
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

    {

    "consumerGroups":
           {
            "size":
            "begin":
            "consumerGroups":[]
           }
           ]
    

    }

获取Topic的groupId列表

描述

本接口用于获取Topic的groupId列表

请求

  • 请求结构

    POST /v{version}/consumergroups/list  HTTP/1.1
    
    {
        "begin":1,
        "limit":10,
        "topicName":"toicDemo"
    }
    
  • 请求头域
    除公共头域外,无其它特殊头域。

  • 请求参数

参数名称 类型 描述
begin requestBody 检索记录开始索引
limit requestBody 要检索的记录数
topic requestBody topic名称

返回

  • 返回头域

    除公共头域,无其它特殊头域。

  • 返回参数

参数名称 类型 描述
begin Integer 检索记录开始索引
limit Integer 要检索的记录数
consumerGroups List\<consumerGroup> consumerGroups信息,由consumerGroup组成的集合

错误码

示例

  • 请求示例

    POST /v1/consumergroups/list
    authorization: bce-auth-v1/32d21dc5-b643-4769-864b-54e3a8868d89/2017-02-16T02:17:25Z/3600/host;x-bce-console-rpc-id;x-bce-date/03a0254357eafd041eb61a2610e938904733cc06a0d3994a7985b62a284874bd
    x-bce-console-rpc-id: 010ce7dc-e454-43ae-a950-75609b39c580
    host: kafka-api.bj.baidubce.com
    x-bce-date: 2017-02-16T02:17:25Z
    content-type: application/json
    user-agent: Jersey/2.9.1 (Apache HttpClient 4.3.3)
    content-length: 53
    connection: Keep-Alive
    accept-encoding: gzip,deflate
    
    {
        "begin":1,
        "limit":10,
        "topicName":"toicDemo"
    }
    
  • 返回示例

    HTTP/1.1 200 OK
    Transfer-Encoding: chunked
    Cache-Control: no-cache
    Server: BWS
    Date: Thu, 16 Feb 2017 02:17:26 GMT
    Content-Type: application/json;charset=UTF-8
    

    {

    "begin": 0,
           "size": 10,
           "groupIds": ["group1","group2"]
    

    }