Какова роль Connector API?

Connector API является частью Kafka Connect — инфраструктуры для интеграции внешних систем с Kafka. Он упрощает подключение различных источников данных (Source Connectors) и систем-приёмников (Sink Connectors), обеспечивая автоматическое перемещение данных между ними без написания кода продюсеров и консюмеров.

На собеседовании: приведите пример: JDBC Source Connector читает изменения из PostgreSQL и отправляет в Kafka, а Elasticsearch Sink Connector пишет данные из Kafka в Elasticsearch. Это CDC (Change Data Capture) без кода.