Managed Service for Apache Kafka® API, REST: User.Create
Creates a Kafka user in the specified cluster.
HTTP request
POST https://mdb.api.cloud.yandex.net/managed-kafka/v1/clusters/{clusterId}/users
Path parameters
Field |
Description |
clusterId |
string Required field. ID of the Apache Kafka® cluster to create a user in. To get the cluster ID, make a ClusterService.List request. |
Body parameters
{
"userSpec": {
"name": "string",
"password": "string",
"permissions": [
{
"topicName": "string",
"role": "string",
"allowHosts": [
"string"
]
}
]
}
}
Field |
Description |
userSpec |
Required field. Configuration of the user to create. |
UserSpec
Field |
Description |
name |
string Required field. Name of the Kafka user. |
password |
string Required field. Password of the Kafka user. |
permissions[] |
Set of permissions granted to the user. |
Permission
Field |
Description |
topicName |
string Name or prefix-pattern with wildcard for the topic that the permission grants access to. To get the topic name, make a TopicService.List request. |
role |
enum (AccessRole) Access role type to grant to the user.
|
allowHosts[] |
string Lists hosts allowed for this permission. Bare in mind that the same host might appear in multiple permissions at the same time, |
Response
HTTP Code: 200 - OK
{
"id": "string",
"description": "string",
"createdAt": "string",
"createdBy": "string",
"modifiedAt": "string",
"done": "boolean",
"metadata": {
"clusterId": "string",
"userName": "string"
},
// Includes only one of the fields `error`, `response`
"error": {
"code": "integer",
"message": "string",
"details": [
"object"
]
},
"response": {
"name": "string",
"clusterId": "string",
"permissions": [
{
"topicName": "string",
"role": "string",
"allowHosts": [
"string"
]
}
]
}
// end of the list of possible fields
}
An Operation resource. For more information, see Operation.
Field |
Description |
id |
string ID of the operation. |
description |
string Description of the operation. 0-256 characters long. |
createdAt |
string (date-time) Creation timestamp. String in RFC3339 To work with values in this field, use the APIs described in the |
createdBy |
string ID of the user or service account who initiated the operation. |
modifiedAt |
string (date-time) The time when the Operation resource was last modified. String in RFC3339 To work with values in this field, use the APIs described in the |
done |
boolean If the value is |
metadata |
Service-specific metadata associated with the operation. |
error |
The error result of the operation in case of failure or cancellation. Includes only one of the fields The operation result. |
response |
The normal response of the operation in case of success. Includes only one of the fields The operation result. |
CreateUserMetadata
Field |
Description |
clusterId |
string ID of the Apache Kafka® cluster the user is being created in. |
userName |
string Name of the user that is being created. |
Status
The error result of the operation in case of failure or cancellation.
Field |
Description |
code |
integer (int32) Error code. An enum value of google.rpc.Code |
message |
string An error message. |
details[] |
object A list of messages that carry the error details. |
User
A Kafka user.
For more information, see the Operations -> Accounts section of the documentation.
Field |
Description |
name |
string Name of the Kafka user. |
clusterId |
string ID of the Apache Kafka® cluster the user belongs to. To get the Apache Kafka® cluster ID, make a ClusterService.List request. |
permissions[] |
Set of permissions granted to this user. |
Permission
Field |
Description |
topicName |
string Name or prefix-pattern with wildcard for the topic that the permission grants access to. To get the topic name, make a TopicService.List request. |
role |
enum (AccessRole) Access role type to grant to the user.
|
allowHosts[] |
string Lists hosts allowed for this permission. Bare in mind that the same host might appear in multiple permissions at the same time, |