Как работает Kafka Connect и Debezium для CDC?

Kafka Connect — фреймворк для коннекторов между Kafka и внешними системами. Source коннекторы тянут данные в Kafka, Sink коннекторы пишут из Kafka. Debezium — source connector, читает database transaction log (binlog MySQL, WAL PostgreSQL) и публикует события изменений. Каждый INSERT/UPDATE/DELETE = Kafka сообщение с before/after состоянием. Преимущества над polling: все изменения (включая прямые SQL), низкая latency, нет нагрузки на БД.