Amazon Aurora and Debezium source connector

To test MSK Connect, we stream data changes events from our database (salesdb) to Amazon MSK. To do so, We use Debezium, an open-source distributed platform for the Change Data Capture (CDC) built on top of Apache Kafka.

We use a MySQL-compatible Amazon Aurora database as the source and the Debezium MySQL connector with the setup shown in the following architectural diagram:

Debezium Source Connector Diagram