Создание топика

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

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на имя нужного кластера и перейдите на вкладку Топики.
Нажмите кнопку Создать топик.
Укажите параметры топика:
- (опционально) Имя — измените автоматически сгенерированное имя топика. Позже это имя (name) и созданный из него идентификатор (ID) нельзя изменить, меняется только отображаемое имя (display name) топика.
- Количество разделов — укажите количество разделов топика.
- Фактор репликации — укажите количество копий каждого раздела.
- Настройки топика — задайте настройки топика.
- (опционально) Описание — добавьте описание топика.
Нажмите кнопку Создать.

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

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

1
mws mkafka topic create <имя топика> \
2
  --cluster <имя кластера> \
3
  --partitions <количество разделов — например, 2> \
4
  --replication-factor <количество реплик для каждого раздела — например, 1>

1
metadata:
2
    createTime: "2025-10-22T04:04:51Z"
3
    updateTime: "2025-10-22T04:04:51Z"
4
    id: mkafka/projects/<имя проекта>/clusters/<имя кластера>/topics/<имя топика>
5
spec:
6
    partitions: 2
7
    replicationFactor: 1
8
status:
9
    ready:
10
        state: PROCESSING

Убедитесь, что у вас есть 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/<имя кластера>/topics/<имя топика> \
2
  -H "Authorization: Bearer <IAM-токен>" \
3
  -H "Content-Type: application/json" \
4
  -d '{
5
    "spec": {
6
      "partitions": <количество разделов — целое число>,
7
      "replicationFactor": <количество копий каждого раздела — целое число не больше количества брокеров>,
8
      "config": <дополнительные параметры Kafka-конфигурации — например, "#max.message.bytes = 500000\ncleanup.policy = compact"
9
    }
10
  }'

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