Создание Kafka коннектора#

Пререквизиты#

• модули приложения развернуты;

• граф репликации создан;

• пользователь авторизовался под ролью APPADMIN или APPDUTY;

• проект Kafka Connect создан.

Процесс#

1. Пользователь инициирует создание коннектора через веб-интерфейс. UI делает REST-запрос к API Console GraDeLy: POST /connectors.

2. Console пересылает запрос к Kafka Connect Worker (KCW) по REST API. В случае отказа KCW, запрос автоматически перенаправляется к следующему в списке воркеру.

3. Kafka Connect Worker при необходимости делегирует выполнение другим KCW, публикуя событие в Kafka (в системный топик).

4. Console возвращает UI информацию об успешной отправке задачи.

Альтернативный сценарий#

Если в течение 30 секунд ни один из KCW не ответит — UI отображает сообщение о недоступности Kafka Connect кластера.