Kafka Connect connector configuration¶

Примеры3B · Общие setup/версии · Фактические проверки (архив рабочего проекта)

Тип материала: учебное практическое упражнение. Выполненные и непроверенные шаги указаны отдельно.

Команды выполняются из examples/processing после общего setup; $labPython — interpreter venv. Runtime и documented expected result различаются.

Зависимости и версии¶

Reference Connect4.1; actual image Debezium3.3.1.Final включает собственный worker, version/commit inspect GET /. requests2.32.5; config, validate/register.

Команды запуска¶

Invoke-RestMethod http://localhost:18083/connector-plugins
& $labPython connect/validate_register.py
Invoke-RestMethod http://localhost:18083/connectors/handbook-postgres-v1/status

Тестовые данные¶

PG fixture payment_fact и publication handbook_pub; JSON converter schemas=true для value. Stable connector name, topic prefix, slot/publication задают integration identity.

Ожидаемый результат¶

REST validation error_count=0 только на правильно загруженном plugin/config. Затем PUT config создаёт/обновляет isolated demo connector; status должен достичь RUNNING/snapshot/streaming по runtime. tasks.max=1 не обещает arbitrary scalability.

Ограничения и статус проверки¶

JSON syntax/Compose model проверены, REST/plugin validation НЕ выполнены. Не ставить sink-style DLQ settings на source как обещание доставки любой ошибки. Изменять slot/topic prefix без migration protocol опасно.

Полный журнал ограничений (архив рабочего проекта) хранит NOT_RUN и failed runtime attempts; их нельзя считать выполненными integration tests.