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

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

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

1. Если у вас нет утилиты MWS CLI:

   1. Установите утилиту.

   2. Инициализируйте профиль.

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

   1
   mws mkafka cluster list

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

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

   Пример вывода команды

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

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

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

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

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

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

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

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

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

1. Если у вас нет утилиты MWS CLI:

   1. Установите утилиту.

   2. Инициализируйте профиль.

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

   1
   mws mkafka cluster list

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

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

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

   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

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

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

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

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

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

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

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

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

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

1. Если у вас нет утилиты MWS CLI:

   1. Установите утилиту.

   2. Инициализируйте профиль.

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

   1
   mws mkafka cluster list

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

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

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

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

   В случае успешного удаления на экран будет выведен ответ success.

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

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

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

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

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

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

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

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