Создание 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 кластера.