更新时间:2024-04-08 GMT+08:00

创建消费组或批量删除消费组

功能介绍

创建消费组或批量删除消费组。

URI

POST /v2/{project_id}/instances/{instance_id}/groups

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

项目ID,获取方式请参见获取项目ID

instance_id

String

实例ID。

表2 Query参数

参数

是否必选

参数类型

描述

action

String

批量删除消费组时使用,不配置则为创建接口。删除操作:delete。

请求参数

表3 请求Body参数

参数

是否必选

参数类型

描述

groups

Array of strings

待删除的消费组列表。

name

String

消费组名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。

brokers

Array of strings

关联的代理列表。

broadcast

Boolean

是否广播。

retry_max_time

Integer

最大重试次数,取值范围为1~16。

enabled

Boolean

是否可以消费。

consume_orderly

Boolean

是否按序消费。

group_desc

String

消费组描述,长度0~200个字符。

最小长度:0

最大长度:200

响应参数

状态码: 200

表4 响应Body参数

参数

参数类型

描述

job_id

String

删除消费组的任务ID

name

String

创建成功的消费组名称。

请求示例

  • 创建一个消费组,不允许以广播模式消费,不按序消费,最大重试次数为16。

    POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups
    
    {
      "name" : "consumer-group-test",
      "group_desc" : "group_description",
      "consume_orderly" : false,
      "broadcast" : false,
      "retry_max_time" : 16
    }
  • 删除消费组consumer-group-test。

    POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups?action=delete
    
    {
      "groups" : [ "consumer-group-test" ]
    }

响应示例

状态码: 200

创建消费组或批量删除消费组成功。

{
  "name" : "consumer-group-test"
}

状态码

状态码

描述

200

创建消费组或批量删除消费组成功。

错误码

请参见错误码