总览

操作接口

cluster

查询clusterId以及clusterName全量数据 （get)

示例:

curl -X GET /v1/cluster

返回值:

{
  "errMsg": "",
  "errCode": 0,
  "result": true,
  "data": "[{\"clusterId\":1,\"clusterName\":\"1124\", \"masterIp\":\"127.0.0.1\"}]"
}

topic

添加topicTask

参数:

type     必填) 请求类型，字段填写：op_query
clusterId   (必填) 请求集群id
addTopicTasks (必填) topicTasks，创建task任务json
user    (必填) 之后接入权限验证需要验证用户，这里预留出来

addTopicTasks目前只包括一个字段为topicName 之后接入region设计会新加入region字段表示不同区域的broker 目前一个addTopicTask会在cluster中的所有broker创建topic

AddTopicTasks 为以下对象的List，可携带多个创建topic请求

topicName (必填) topic名称

示例:

【POST】 /v1/task?method=addTopicTask

curl -X POST /v1/task?method=addTopicTask -H "Content-Type: application/json" -d '{
  "clusterId": "1",
  "addTopicTasks": [
    {
      "topicName": "1"
    }
  ],
  "user": "test"
}'

返回json格式样例:

{
  "errMsg": "There are topic tasks [a12322] already in adding status",
  "errCode": 200,
  "result": false,
  "data": ""
}

result为false为写入task失败

查询某一个topic是否创建成功（业务可以写入）

clusterId   (必填) 请求集群id
topicName   (必填) 查询topic名称
user    (必填) 之后接入权限验证需要验证用户，这里预留出来

示例:

curl -X POST /v1/topic?method=queryCanWrite -H "Content-Type: application/json" -d '{
  "clusterId": "1",
  "topicName": "1",
  "user": "test"
}'

返回json格式样例:

{ 
  "result":true, 
  "errCode":0, 
  "errMsg":"OK"
}

{ 
  "result":false, 
  "errCode": 100, 
  "errMsg":"topic test is not writable"
}

{ 
  "result":false, 
  "errCode": 101, 
  "errMsg":"no such topic in master"
}

result为false为不可写