创建集群
更新时间:2024-01-03
该接口用于创建集群。
- 针对创建集群白名单中的用户。
请求结构
Java
1POST /v{version}/clusters HTTP/1.1
2Host: kafka-api.bj.baidubce.com
3Authorization: authorization string
请求头域
除公共头域外,无其他特殊头域。
请求参数
参数名称 | 类型 | 是否必须 | 参数位置 | 描述 |
---|---|---|---|---|
version | String | 是 | URL参数 | API版本号 |
name | String | 是 | Request Body参数 | 集群名称 |
mode | String | 是 | Request Body参数 | 部署模式, HP、HA |
type | String | 是 | Request Body参数 | 部署类型,PROVISIONED、SERVERLESS |
provisioned | Provisioned | 是 | Request Body参数 | provisioned 集群类型的参数,参见Provisioned |
tags | List<Tag> | 否 | Request Body参数 | 标签列表 |
返回头域
除公共头域外,无其他特殊头域。
返回参数
参数名称 | 类型 | 描述 |
---|---|---|
clusterId | String | 集群ID |
错误码
错误码 | 错误描述 | HTTP状态码 | 描述 |
---|---|---|---|
ERROR_PARAMS | 请求参数错误 | 400 | 请求参数错误 |
CLUSTER_NOT_FOUND | 集群重名 | 400 | 集群重名 |
IMAGE_NOT_FOUND | 未找到镜像 | 451 | 未找到镜像 |
RESOURCE_FAILED | 资源达到上限 | 451 | 资源达到上限 |
STOCK_FAILED | 库存不足 | 451 | 库存不足 |
RESOURCE_NOT_FOUND | 资源已下架 | 451 | 资源已下架 |
INTERNAL_ERROR | 服务内部错误 | 500 | 服务内部错误 |
请求示例
Java
1POSt http://kafka-api.bj.baidubce.com/v2/clusters
2Authorization: bce-auth-v1/ALTAKaiKeDfBD880eMWBE5oIGE/2023-05-08T11:43:45Z/1800/host;x-bce-date/322f3f98ce57d296c0f5abc64e5554b640ea035c5cb462fcaeab54b9810a3c61
3Host: kafka-api.bj.baidubce.com
4{
5 "name": "demo",
6 "mode": "HP",
7 "type": "PROVISIONED",
8 "provisioned": {
9 "kafkaVersion": "2.7.2",
10 "nodeType": "kafka.g4.c2m8",
11 "configMeta": {
12 "configId": null,
13 "revisionId": null,
14 "context": {
15 "log.retention.hours":"24"
16 }
17 },
18 "numberOfBrokerNodes": 3,
19 "storageMeta": {
20 "storageType": "ENHANCED_SSD_PL1",
21 "storageSize": 100,
22 "numberOfDisk": 1
23 },
24 "storagePolicyEnabled": true,
25 "storagePolicy": {
26 "type": "AUTO_DELETE",
27 "autoDelete": {
28 "diskUsedThresholdPercent": 75,
29 "logMinRetentionMs": 3600000,
30 "logMinRetentionBytes": 2147483648
31 }
32 },
33 "deploySetEnabled": false,
34 "billing": {
35 "payment": "Prepaid",
36 "timeLength":1,
37 "timeUnit":"month",
38 "autoRenewEnabled": true,
39 "autoRenewTimeLength": 1,
40 "autoRenewTimeUnit": "month",
41 "couponIds":[
42 "xxxxx"
43 ],
44 "isAutoPay": true,
45 },
46 "vpcId": "vpc-tf3xqatke54b",
47 "subnetIds": [
48 "sbn-12kruawmu30u"
49 ],
50 "publicIpEnabled": false,
51 "publicIpBandwidth": 0,
52 "intranetIpEnabled": false,
53 "aclEnabled": true,
54 "authentications": [
55 {
56 "mode": "NONE"
57 }
58 ]
59 },
60 "tags": [
61 {
62 "tagKey": "KAFKA-Cluster",
63 "tagValue": ""
64 }
65 ]
66}
返回示例
Java
1HTTP/1.1 200 OK
2x-bce-request-id: 97e6d4ad-6fca-4609-ad4d-9a27c4d1a362
3Date: Mon, 08 May 2023 09:39:11 GMT
4Content-Type: application/json;charset=UTF-8
5Server: BWS
6
7{
8 "clusterId": "33a168bb70c0459787416077114ab233"
9}