Debezium

RU: Debezium

An open-source platform of Kafka Connect source connectors that implements log-based change data capture (CDC). It tails the native transaction log of a database — binlog for MySQL, WAL for PostgreSQL — and emits a structured change event (with before/after row state and metadata) to a Kafka topic for every INSERT, UPDATE, or DELETE. Because it reads the log rather than polling tables, it captures deletes and schema changes with low latency and no impact on the source workload.