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

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

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

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

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

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

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

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

1
+------------------+-------------+------------+----------------------+
2
|       NAME       | DESCRIPTION |   STATUS   |      UPDATE TIME     |
3
+------------------+-------------+------------+----------------------+
4
| <имя коннектора> |             | OK         | 2026-08-10T12:50:25Z |
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/<имя кластера>/connectors \
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 connector list --cluster <имя кластера>

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

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

1
metadata:
2
  displayName: <отображаемое имя коннектора>
3
  createTime: "2026-08-05T22:36:53Z"
4
  updateTime: "2026-08-10T12:50:25Z"
5
  id: mkafka/projects/<имя проекта>/clusters/<имя кластера>/connectors/<имя коннектора>
6
spec:
7
  active: true
8
  s3SinkConnector:
9
    topics: <список топиков-источников>
10
    s3Properties:
11
      bucketName: <имя бакета для записи данных>
12
      accessKeyId: <идентификатор (Acess Key) HMAC-ключа>
13
      endpoint: <S3-эндпоинт>
14
    tasksMax: <максимальное количество параллельно выполняемых задач — например, 1>
15
    inputFormat: <формат входных данных — например, STRING>
16
    outputFormat: <формат выходных данных — JSONL>
17
    fileCompressionType: <тип сжатия файлов — например, NONE>
18
    outputFields:
19
      - <поле для записи — например, KEY>
20
      - <поле для записи — например, VALUE>
21
    outputEnvelope: true
22
    errorHandling: <политика обработки ошибок — DLQ>
23
    dlqTopic: <имя DLQ-топика>
24
status:
25
  ready:
26
    state: OK
27
  state: RUNNING
28
  health: ALIVE

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

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

Выполните команду:
bash
```
1
mws mkafka connector stop <имя коннектора> --cluster <имя кластера>
```
Если коннектор был остановлен успешно, в ответе будут выведены обновленные параметры коннектора.

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

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

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

Запустить коннектор

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

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

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

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

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

Выполните команду:
bash
```
1
mws mkafka connector start <имя коннектора> --cluster <имя кластера>
```
Если коннектора был запущен успешно, в ответе будут выведены обновленные параметры коннектора.

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

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

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

Изменить режим выбора топиков или топики-источники

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

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

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

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

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

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

1
mws mkafka connector update <имя коннектора> \
2
  --cluster <имя кластера> \
3
  --s3-sink-connector-topics <имя топика 1>,<имя топика 2> \  # Если указываются конкретные топики
4
  --s3-sink-connector-topics-regex ^<префикс-топика>-.*$  # Если указывается регулярное выражение

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

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

Опишите обновления в конфигурации коннектора в виде JSON-объекта. В конфигурации укажите новый способ обработки данных и топики, из которых будут читаться данные:

1
{
2
  "spec": {
3
    "s3SinkConnector": {
4
      "topics": "<имя топика 1>,<имя топика 2>", // Если указываются конкретные топики
5
      "topicsRegex": "^<префикс-топика>-.*$" // Если указывается регулярное выражение
6
    }
7
  }
8
}

Выполните запрос:
bash
```
1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>/connectors/<имя коннектора> \
2
  -H "Authorization: Bearer <IAM-токен>" \
3
  -H "Content-Type: application/json" \
4
  -d '@<путь к файлу с JSON-объектом>'
```
Если запрос был успешно принят, вы получите ответ с кодом 200 OK. Если режим выбора топиков и выбор топиков изменены успешно, в ответе будут выведены обновленные параметры коннектора.

Изменить параметры обработки данных

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

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на имя нужного кластера и перейдите на вкладку Коннекторы.
Нажмите на имя нужного коннектора. Откроется страница коннектора.
Нажмите на значок редактирования в блоке Обработка данных.
Измените максимальное количество параллельно выполняемых задач. Уменьшить значение в будущем невозможно.
Измените формат входных данных для десериализации сообщений из топика.
Измените тип сжатия файлов для сохранения в бакет.
Переключите опцию Оборачивать значения в JSON-объект.
Измените поля сообщения из топиков, которые будут записаны в сохраняемый в бакет файл.
Нажмите кнопку Сохранить.

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

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

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

Выполните команду, указав обновляемые параметры, а также топики, из которых читаются данные, даже если они не меняются:

1
mws mkafka connector update <имя коннектора> \
2
  --cluster <имя_кластера> \
3
  --s3-sink-connector-topics <имя топика 1>,<имя топика 2> \  # Если указываются конкретные топики
4
  --s3-sink-connector-topics-regex ^<префикс-топика>-.*$ \  # Если указывается регулярное выражение
5
  --s3-sink-connector-tasks-max <максимальное количество параллельно выполняемых задач> \  # Значение не должно превышать общее количество разделов во всех выбранных топиках
6
  --s3-sink-connector-file-compression-type <тип сжатия файлов — GZIP, SNAPPY, ZSTD или NONE> \
7
  --s3-sink-connector-output-envelope \  # Если нужно сохранять данные как JSON-объект
8
  --s3-sink-connector-output-fields <поле для записи — KEY, VALUE, OFFSET, TIMESTAMP или HEADERS>  # Должно содержать только одно поле, если данные не сохраняются как JSON-объект. Опционально, если данные сохраняются как JSON-объект. Чтобы указать несколько полей, повторите флаг несколько раз

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

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

Опишите обновления в конфигурации коннектора в виде JSON-объекта. В конфигурации также укажите топики, из которых читаются данные, даже если они не меняются.

Пример конфигурации:
json
```
1
{
2
  "spec": {
3
    "s3SinkConnector": {
4
      "topics": "<имя топика 1>,<имя топика 2>",
5
      "tasksMax": 1,
6
      "fileCompressionType": "NONE",
7
      "outputEnvelope": true,
8
      "outputFields": ["KEY","VALUE"]
9
    }
10
  }
11
}
```
Выполните запрос:
bash
```
1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>/connectors/<имя коннектора> \
2
  -H "Authorization: Bearer <IAM-токен>" \
3
  -H "Content-Type: application/json" \
4
  -d '@<путь к файлу с JSON-объектом>'
```
Если запрос был успешно принят, вы получите ответ с кодом 200 OK. Если параметры обработки данных в коннекторе изменен успешно, в ответе будут выведены обновленные параметры коннектора.

Изменить DLQ-топик

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

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

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

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

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

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

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

Выполните команду, указав новый DLQ-топик, а также топики, из которых читаются данные, даже если они не меняются:

1
mws mkafka connector update <имя коннектора> \
2
  --cluster <имя кластера> \
3
  --s3-sink-connector-dlq-topic <имя нового DLQ-топика> \
4
  --s3-sink-connector-topics <имя топика 1>,<имя топика 2> \  # Если указываются конкретные топики
5
  --s3-sink-connector-topics-regex ^<префикс-топика>-.*$ \  # Если указывается регулярное выражение

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

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

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

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

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

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

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

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

Опишите обновления в конфигурации коннектора в виде JSON-объекта. В конфигурации также укажите топики, из которых читаются данные, даже если они не меняются.

Пример конфигурации:
json
```
1
{
2
  "spec": {
3
    "s3SinkConnector": {
4
      "topics": "<имя топика 1>,<имя топика 2>",
5
      "dlqTopic": "<имя нового DLQ-топика>"
6
    }
7
  }
8
}
```

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

1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>/connectors/<имя коннектора> \
2
  -H "Authorization: Bearer <IAM-токен>" \
3
  -H "Content-Type: application/json" \
4
  -d '@<путь к файлу с JSON-объектом>'

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

Изменить S3-параметры коннектора

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

В веб-консоли выберите нужный проект.
В списке сервисов выберите Managed Kafka.
Нажмите на имя нужного кластера и перейдите на вкладку Коннекторы.
Нажмите на имя нужного коннектора. Откроется страница коннектора.
Нажмите на значок редактирования в блоке Доступ к бакету.
Измените эндпоинт на эндпоинт MWS Object Storage https://storage.mwsapis.ru или на сторонний S3-совместимый.
Укажите бакет или создайте новый.
Введите идентификатор (Access Key) и секретную часть (Secret Key) существующего HMAC-ключа сервисного аккаунта или создайте новый HMAC-ключ.
Нажмите кнопку Сохранить.

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

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

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

Выполните команду, указав обновленные параметры, а также топики, из которых читаются данные, даже если они не меняются:

1
mws mkafka connector update <имя коннектора> \
2
  --cluster <имя кластера> \
3
  --s3-sink-connector-topics <имя топика 1>,<имя топика 2> \  # Если указываются конкретные топики
4
  --s3-sink-connector-topics-regex ^<префикс-топика>-.*$ \  # Если указывается регулярное выражение
5
  --s3-sink-connector-s3-properties-bucket-name <имя нового бакета для записи данных> \
6
  --s3-sink-connector-s3-properties-access-key-id <идентификатор (Acess Key) HMAC-ключа> \
7
  --s3-sink-connector-s3-properties-secret-access-key <секретная часть (Secret Key) HMAC-ключа> \
8
  --s3-sink-connector-s3-properties-endpoint <S3-эндпоинт>

Если настройки доступа к S3-хранилищу в коннекторе изменены успешно, в ответе будут выведены обновленные параметры коннектора.

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

Опишите обновления в конфигурации коннектора в виде JSON-объекта. В конфигурации укажите обновления параметра s3Properties, а также укажите способ обработки данных и топики, из которых будут читаться данные, даже если они не меняются.

Пример конфигурации:
json
```
1
{
2
  "spec": {
3
    "s3SinkConnector": {
4
      "topics": "<имя топика 1>,<имя топика 2>",
5
      "s3Properties": {
6
        "bucketName": "<имя нового бакета для записи данных>"
7
      }
8
    }
9
  }
10
}
```
Выполните запрос:
bash
```
1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>/connectors/<имя коннектора> \
2
  -H "Authorization: Bearer <IAM-токен>" \
3
  -H "Content-Type: application/json" \
4
  -d '@<путь к файлу с JSON-объектом>'
```
Если запрос был успешно принят, вы получите ответ с кодом 200 OK. Если настройки доступа к S3-хранилищу в коннекторе изменены успешно, в ответе будут выведены обновленные параметры коннектора.

Переименовать коннектор

Вы можете изменить только отображаемое имя коннектора. Идентификатор коннектора при этом не изменится.

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

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

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

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

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

Выполните команду:
bash
```
1
mws mkafka connector update <имя коннектора> \
2
  --cluster <имя кластера> \
3
  --display-name <новое отображаемое имя коннектора>
```
Если коннектор был переименован успешно, в ответе будут выведены обновленные параметры коннектора.

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

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

1
curl -X POST https://mkafka.mwsapis.ru/mkafka/v1/projects/<имя проекта>/clusters/<имя кластера>/connectors/<имя коннектора> \
2
  -H "Authorization: Bearer <IAM-токен>" \
3
  -H "Content-Type: application/json" \
4
  -d '{
5
    "metadata": {
6
    "displayName": "<новое отображаемое имя коннектора>"
7
      }
8
    }'

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

Удалить коннектор

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

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

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

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

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

Выполните команду:
bash
```
1
mws mkafka connector 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/<имя кластера>/connectors \
2
  -H "Authorization: Bearer <IAM-токен>"

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

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

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