Debezium

Debezium is a Kafka Connect connector that uses database Change Data Capture (CDC) logs to detect changes to SQL tables in real time and stream changes up to a Kafka instance.