Debezium

EN: Debezium

Открытая платформа source-коннекторов для Kafka Connect, реализующая log-based change data capture (CDC). Debezium читает нативный журнал транзакций базы данных — binlog для MySQL, WAL для PostgreSQL — и публикует в Kafka-топик структурированное событие изменения (с состоянием строки до/после и метаданными) для каждой операции INSERT, UPDATE или DELETE. Чтение журнала вместо опроса таблиц позволяет захватывать удаления и изменения схемы с малой задержкой и без нагрузки на источник.