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

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

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

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

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

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

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

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

1
+--------------+----------------------+------------+--------------------+
2
|     NAME     | RECONCILIATION STATE | PARTITIONS | REPLICATION FACTOR |
3
+--------------+----------------------+------------+--------------------+
4
| <имя топика> | OK                   | 1          | 1                  |
5
+--------------+----------------------+------------+--------------------+

Убедитесь, что у вас есть 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/<имя кластера>/topics \
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 topic list --cluster <имя кластера>

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

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

1
metadata:
2
    displayName: topic-fabruq
3
    createTime: "2025-10-17T09:32:17Z"
4
    updateTime: "2025-10-17T09:32:17Z"
5
    description: "<описание топика>"
6
    id: mkafka/projects/<имя проекта>/clusters/<имя кластера>/topics/<имя топика>
7
spec:
8
    partitions: <количество разделов — например, 1>
9
    replicationFactor: <количество реплик для каждого раздела — например, 1>
10
status:
11
    ready:
12
        state: OK

Убедитесь, что у вас есть 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/<имя кластера>/topics \
2
  -H "Authorization: Bearer <IAM-токен>"

Выполните запрос:
bash
```
1
curl -X GET https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>/topics/<имя топика> \
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 topic list --cluster <имя кластера>

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

1
mws mkafka topic update <имя топика> \
2
  --cluster <имя кластера> \
3
  --partitions <количество разделов — например, 3>  # Уменьшить количество разделов нельзя

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

Убедитесь, что у вас есть 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/<имя кластера>/topics \
2
  -H "Authorization: Bearer <IAM-токен>"

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

1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>/topics/<имя топика> \
2
  -H "Authorization: Bearer <IAM-токен>" \
3
  -H "Content-Type: application/json" \
4
  -d '{
5
    "spec": {
6
      "partitions": <количество разделов — целое число>  // Уменьшить количество разделов нельзя
7
    }
8
  }'

Если запрос был успешно принят, вы получите ответ с кодом 200 OK. Если количество разделов было изменено успешно, в ответе будут выведены обновленные параметры топика.

Удалить топик

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

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

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

Узнайте имя топика:

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

Выполните команду:
bash
```
1
mws mkafka topic delete <имя топика> --cluster <имя кластера>
```
В случае успешного удаления на экран будет выведен ответ success.

Убедитесь, что у вас есть 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/<имя кластера>/topics \
2
  -H "Authorization: Bearer <IAM-токен>"

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

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

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