Управление кластером

Получить список кластеров

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.

Откроется список кластеров проекта.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.

Выполните команду:

1
mws mkafka cluster list

1
+----------------+-----------------------------+---------+----------+--------------+---------------+----------------------+
2
|      NAME      |        DISPLAY NAME         | VERSION |  STATUS  |     STATE    | BROKERS COUNT |     DATE CREATED     |
3
+----------------+-----------------------------+---------+----------+--------------+---------------+----------------------+
4
| <имя кластера> | <отображаемое имя кластера> | 4.0     | ALIVE    | RUNNING      | 3             | 2025-10-17T09:31:36Z |
5
+----------------+-----------------------------+---------+----------+--------------+---------------+----------------------+

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.
Выполните запрос:
bash
```
1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"
```
Если запрос был успешно принят, вы получите ответ с кодом 200 OK. В ответе будет выведен список доступных кластеров проекта с детализацией параметров.

Получить информацию о конкретном кластере

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на имя нужного кластера.

Откроется страница кластера.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.
Узнайте имя кластера:
bash
```
1
mws mkafka cluster list
```

Выполните команду:

1
mws mkafka cluster get <имя кластера>

1
metadata:
2
    displayName: <отображаемое имя кластера>
3
    createTime: "2025-10-17T09:31:36Z"
4
    updateTime: "2025-10-21T21:21:49Z"
5
    description: ""
6
    id: mkafka/projects/<имя проекта>/clusters/<имя кластера>
7
spec:
8
    active: true
9
    version: "4.0"
10
    endpoints:
11
        - name: network1
12
          network: projects/<имя проекта>/networks/<имя сети>
13
          brokerAddresses:
14
            - spec:
15
                subnet: projects/<имя проекта>/networks/<имя сети>/subnets/<имя подсети>
16
            - spec:
17
                subnet: projects/<имя проекта>/networks/<имя сети>/subnets/<имя подсети>
18
            - spec:
19
                subnet: projects/<имя проекта>/networks/<имя сети>/subnets/<имя подсети>
20
    instances:
21
        broker:
22
            vmType: vmTypes/gen-2-8
23
            disk:
24
                size: <размер диска в гигабайтах — например, 10Gb>
25
                type: <тип диска — например, NETWORK_STANDARD_SSD>
26
            allocation:
27
                - zone: <зона доступности>
28
                  count: <количество узлов — например, 3>
29
        controller:
30
            vmType: vmTypes/gen-2-8
31
            disk:
32
                size: <размер диска в гигабайтах — например, 10Gb>
33
                type: <тип диска — например, NETWORK_STANDARD_SSD>
34
            allocation:
35
                - zone: <зона доступности>
36
                  count: <количество узлов — например, 3>
37
status:
38
    ready:
39
        state: OK
40
    state: RUNNING
41
    health: ALIVE
42
bootstrapServers: broker-<зона доступности>-1.<имя кластера>.<имя проекта>.mkafka.mws:<порт>, broker-<зона доступности>-2.<имя кластера>.<имя проекта>.mkafka.mws:<порт>, broker-<зона доступности>-3.<имя кластера>.<имя проекта>.mkafka.mws:<порт>
43
    endpoints:
44
        - name: <имя эндпоинта>
45
          network: projects/<имя проекта>/networks/<имя сети>
46
          brokerAddresses:
47
            - ref: projects/<имя проекта>/networks/<имя сети>/addresses/<идентификатор адреса брокера 1>
48
              subnet: projects/<имя проекта>/networks/<имя сети>/subnets/<имя подсети>
49
              ipAddress: <IP-адрес брокера 1>
50
              dns:
51
                - name: broker-<зона доступности>-1.<имя кластера>.<имя проекта>.mkafka.mws
52
            - ref: projects/<имя проекта>/networks/<имя сети>/addresses/<идентификатор адреса брокера 2>
53
              subnet: projects/<имя проекта>/networks/<имя сети>/subnets/<имя подсети>
54
              ipAddress: <IP-адрес брокера 2>
55
              dns:
56
                - name: broker-<зона доступности>-2.<имя кластера>.<имя проекта>.mkafka.mws
57
            - ref: projects/<имя проекта>/networks/<имя сети>/addresses/<идентификатор адреса брокера 3>
58
              subnet: projects/<имя проекта>/networks/<имя сети>/subnets/<имя подсети>
59
              ipAddress: <IP-адрес брокера 3>
60
              dns:
61
                - name: broker-<зона доступности>-3.<имя кластера>.<имя проекта>.mkafka.mws
62
    maintenanceWindow:
63
        weekly:
64
            days:
65
                - SUNDAY
66
            hour: 0

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.

Узнайте имя кластера:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:
bash
```
1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
  -H "Authorization: Bearer <IAM-токен>"
```
Если запрос был успешно принят, вы получите ответ с кодом 200 OK. В ответе будут выведены параметры кластера с детализацией.

Остановить кластер

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на значок ... для нужного кластера и выберите Остановить.
Подтвердите остановку.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.
Узнайте имя кластера:
bash
```
1
mws mkafka cluster list
```
Выполните команду:
bash
```
1
mws mkafka cluster stop <имя кластера>
```
Если кластер был остановлен успешно, в ответе будут выведены обновленные параметры кластера.

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.

Узнайте имя кластера:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:
bash
```
1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>:stop \
2
  -H "Authorization: Bearer <IAM-токен>"
```
Если запрос был успешно принят, вы получите ответ с кодом 200 OK. Если кластер был остановлен успешно, в ответе будут выведены обновленные параметры кластера.

После остановки статус кластера изменится на Stopped.

Запустить кластер

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на значок ... для нужного кластера и выберите Запустить.
Подтвердите запуск.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.
Узнайте имя кластера:
bash
```
1
mws mkafka cluster list
```
Выполните команду:
bash
```
1
mws mkafka cluster start <имя кластера>
```
Если кластер был запущен успешно, в ответе будут выведены обновленные параметры кластера.

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.

Узнайте имя кластера:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:
bash
```
1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>:start \
2
  -H "Authorization: Bearer <IAM-токен>"
```
Если запрос был успешно принят, вы получите ответ с кодом 200 OK. Если кластер был запущен успешно, в ответе будут выведены обновленные параметры кластера.

После запуска статус кластера изменится на Running.

Настроить внешний IP-адрес кластера

Назначить внешний IP-адрес

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на имя нужного кластера.
Перейдите на вкладку Сети.
Нажмите на значок редактирования сети. Он находится рядом с кнопкой настройки файрвола.
Выберите тип IP-адреса: временный, который выбирается автоматически из диапазона подсети, или зарезервированный. Выбранный тип адреса применится для всех брокеров кластера.
Если вы выбрали зарезервированный адрес, в блоке Подключение к брокерам для каждого брокера нажмите на значок редактирования и выберите IP-адрес. Если IP-адрес еще не зарезервирован, зарезервируйте его.
Нажмите кнопку Сохранить.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.
Узнайте имя кластера:
bash
```
1
mws mkafka cluster list
```
Узнайте имя эндпоинта и идентификатор его сети:
bash
```
1
mws mkafka cluster get <имя кластера>
```
(опционально) Если вы назначаете зарезервированные IP-адреса, узнайте их идентификаторы:
bash
```
1
mws vpc external-address get <имя адреса>
```

Выполните команду:

Для назначения временных IP
Для назначения зарезервированных IP

1
mws mkafka cluster update <имя кластера> --endpoints '
2
  name: <имя эндпоинта>
3
  network: <идентификатор сети>
4
  externalAccess:
5
    allowed: true
6
'

В случае успеха на экран будет выведена обновленная информация о кластере.

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.

Узнайте имя кластера:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"

Узнайте имя эндпоинта и идентификатор его сети:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
  -H "Authorization: Bearer <IAM-токен>"

(опционально) Если вы назначаете зарезервированные IP-адреса, узнайте их идентификаторы:

1
curl -X GET https://vpc.mwsapis.ru/vpc/v1/projects/<имя проекта>/networks/<имя сети>/addresses \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:

Для назначения временных IP
Для назначения зарезервированных IP

1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
-H "Authorization: Bearer <IAM-токен>" \
3
-H "Content-Type: application/json" \
4
-d '{
5
        "spec": {
6
        "endpoints": [
7
        {
8
        "name": "<имя эндпоинта>",
9
        "network": "<идентификатор сети>",
10
        "externalAccess": {
11
            "allowed": true
12
        }]
13
    }'

В случае успеха в ответе будет выведена обновленная информация о кластере.

Сменить внешний IP-адрес

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на имя нужного кластера.
Перейдите на вкладку Сети.
Нажмите на значок редактирования сети. Он находится рядом с кнопкой настройки файрвола.
Выберите тип IP-адреса: временный, который выбирается автоматически из диапазона подсети, или зарезервированный. Выбранный тип адреса применится для всех брокеров кластера.
Если вы выбрали зарезервированный адрес, в блоке Подключение к брокерам для каждого брокера нажмите на значок редактирования и выберите IP-адрес. Если IP-адрес еще не зарезервирован, зарезервируйте его.
Нажмите кнопку Сохранить.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.
Узнайте имя кластера:
bash
```
1
mws mkafka cluster list
```
Узнайте имя эндпоинта и идентификатор его сети:
bash
```
1
mws mkafka cluster get <имя кластера>
```
(опционально) Если вы назначаете зарезервированные IP-адреса, узнайте их идентификаторы:
bash
```
1
mws vpc external-address get <имя адреса>
```

Выполните команду:

Для назначения временных IP
Для назначения зарезервированных IP

1
mws mkafka cluster update <имя кластера> --endpoints '
2
  name: <имя эндпоинта>
3
  network: <идентификатор сети>
4
  externalAccess:
5
    allowed: true
6
'

В случае успеха на экран будет выведена обновленная информация о кластере.

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.

Узнайте имя кластера:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"

Узнайте имя эндпоинта и идентификатор его сети:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
  -H "Authorization: Bearer <IAM-токен>"

(опционально) Если вы назначаете зарезервированные IP-адреса, узнайте их идентификаторы:

1
curl -X GET https://vpc.mwsapis.ru/vpc/v1/projects/<имя проекта>/networks/<имя сети>/addresses \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:

Для назначения временных IP
Для назначения зарезервированных IP

1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
-H "Authorization: Bearer <IAM-токен>" \
3
-H "Content-Type: application/json" \
4
-d '{
5
        "spec": {
6
        "endpoints": [
7
        {
8
        "name": "<имя эндпоинта>",
9
        "network": "<идентификатор сети>",
10
        "externalAccess": {
11
            "allowed": true
12
        }]
13
    }'

В случае успеха в ответе будет выведена обновленная информация о кластере.

После замены временный IP-адрес вернется в пул провайдера. Зарезервированный IP-адрес останется в проекте, за его хранение продолжит взиматься плата.

Отвязать внешний IP-адрес

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на имя нужного кластера.
Перейдите на вкладку Сети.
Нажмите на значок редактирования сети. Он находится рядом с кнопкой настройки файрвола.
Выберите тип адреса Без адреса.
Нажмите кнопку Сохранить.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.
Узнайте имя кластера:
bash
```
1
mws mkafka cluster list
```
Узнайте имя эндпоинта и идентификатор его сети:
bash
```
1
mws mkafka cluster get <имя кластера>
```

Выполните команду:

1
mws mkafka cluster update <имя кластера> --endpoints '
2
  name: <имя эндпоинта>
3
  network: <идентификатор сети>
4
  externalAccess:
5
    allowed: false
6
'

В случае успеха на экран будет выведена обновленная информация о кластере.

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.

Узнайте имя кластера:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"

Узнайте имя эндпоинта и идентификатор его сети:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:

1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
-H "Authorization: Bearer <IAM-токен>" \
3
-H "Content-Type: application/json" \
4
-d '{
5
        "spec": {
6
        "endpoints": [
7
        {
8
        "name": "<имя эндпоинта>",
9
        "network": "<идентификатор сети>",
10
        "externalAccess": {
11
            "allowed": false,
12
            "brokerAddresses": []  // Для отвязывания зарезервированных адресов
13
        }]
14
    }'

В случае успеха в ответе будет выведена обновленная информация о кластере.

Временный IP-адрес вернется в пул провайдера. Зарезервированный IP-адрес останется в проекте, за его хранение продолжит взиматься плата.

Удалить кластер

Веб-консоль
MWS CLI
API

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на значок ... для удаляемого кластера и выберите Удалить.
Подтвердите удаление.

Если у вас нет утилиты MWS CLI:
1. Установите утилиту.
2. Инициализируйте профиль.
Узнайте имя кластера:
bash
```
1
mws mkafka cluster list
```
Выполните команду:
bash
```
1
mws mkafka cluster delete <имя кластера>
```
В случае успешного удаления на экран будет выведен ответ success.

Убедитесь, что у вас есть IAM-токен для авторизации запроса. Если нет, получите его.

Узнайте имя кластера:

1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:

1
curl -X DELETE https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера> \
2
  -H "Authorization: Bearer <IAM-токен>"

Если кластер был успешно удален, вы получите ответ с кодом 204 No Content.