Overview
Operation interface
cluster
Query full data of clusterId and clusterName (get)
Example
【GET】 /v1/cluster
return value
{
"errMsg": "",
"errCode": 0,
"result": true,
"data": "[{\"clusterId\":1,\"clusterName\":\"1124\", \"masterIp\":\"127.0.0.1\"}]"
}
topic
add topicTask
parameter:
type (required) request type, fill in the field: op_query
clusterId (required) Request cluster id
addTopicTasks (required) topicTasks, create task task json
user (required) After the access authorization verification needs to verify the user, it is reserved here
addTopicTasks currently only includes one field as topicName After accessing the region design, a new region field will be added to represent brokers in different regions Currently an addTopicTask will create topics in all brokers in the cluster
AddTopicTasks is a list of the following objects, which can carry multiple create topic requests
topicName (required) topic name
Example
【POST】 /v1/task?method=addTopicTask
{
"clusterId": "1",
"addTopicTasks": [{"topicName": "1"}],
"user": "test"
}
return json
{
"errMsg": "There are topic tasks [a12322] already in adding status",
"errCode": 200,
"result": false,
"data": ""
}
If result is false, the writing task failed
Query whether a topic is successfully created (business can be written)
clusterId (Required) Request cluster id
topicName (Required) Query topic name
user (Required) After the access authorization verification needs to verify the user, it is reserved here
example
【POST】 /v1/topic?method=queryCanWrite
{
"clusterId": "1",
"topicName": "1",
"user": "test"
}
return 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 is false as not writable