更新时间:2026-01-27 GMT+08:00

设置用户权限

功能介绍

设置用户权限。

Kafka实例开启SASL功能时,才支持多用户管理的功能。

URI

POST /v1/{project_id}/instances/{instance_id}/topics/accesspolicy

表1 路径参数

参数

是否必选

参数类型

描述

project_id

是

String

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

instance_id

是

String

实例ID。

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

topics

是

Array of AccessPolicyTopicEntity objects

topic列表。

表3 AccessPolicyTopicEntity

参数

是否必选

参数类型

描述

name

是

String

topic名称。

policies

是

Array of AccessPolicyEntity objects

权限列表。

表4 AccessPolicyEntity

参数

是否必选

参数类型

描述

user_name

否

String

用户名称。

设置用户权限时,为必选参数。

access_policy

否

String

权限类型。

  • all:拥有发布、订阅权限;

  • pub:拥有发布权限;

  • sub:拥有订阅权限。

设置用户权限时,为必选参数。

响应参数

状态码: 400

表5 响应Body参数

参数

参数类型

描述

error_code

String

错误码。

error_msg

String

错误描述。

状态码: 403

表6 响应Body参数

参数

参数类型

描述

error_code

String

错误码。

error_msg

String

错误描述。

请求示例

设置用户权限,为root用户授予发布和订阅topic-test的权限。

POST https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/accesspolicy

{
  "topics" : [ {
    "name" : "topic-test",
    "policies" : [ {
      "user_name" : "root",
      "access_policy" : "all"
    } ]
  } ]
}

响应示例

无

状态码

状态码

描述

204

更新成功。

400

参数无效。

403

鉴权失败。

错误码

请参见错误码。