Module cdc 

Change Data Capture connectors for databases. Change Data Capture (CDC) source connectors. PostgreSQL uses logical replication (pgoutput); MySQL uses the binary log with GTID support.

Modules

mysql

MySQL binlog replication CDC source connector. Reads row-level changes from a MySQL server’s binlog (GTID or file/position based), decodes them via the decoder submodule, resolves column types against schema::TableCache, and emits Z-set changelog::ChangeEvents that MySqlCdcSource converts into Arrow RecordBatches on poll_batch.

postgres

PostgreSQL CDC source connector.