Use Debezium to capture MySQL or PostgreSQL change events and stream them to Kafka

Steps

1. Enable the database's binary log (MySQL: binlog_format=ROW; PostgreSQL: wal_level=logical and create a replication slot) and grant Debezium a user with replication privileges
2. Deploy the Debezium source connector via Kafka Connect REST API with the appropriate connector class and database connection properties
3. Verify that the connector performs an initial snapshot of existing table data by reading the snapshot.mode setting (default: initial)
4. Monitor the Kafka topic for the captured table (named by default as server.schema.table) and confirm that insert, update, and delete events appear with the correct before and after payloads
5. Configure tombstone events and topic cleanup policy (compact) on the Kafka topic to support downstream consumers that rely on log compaction for key-based deduplication