id: io-cdc title: CDC connector sidebar_label: CDC connector

CDC source connectors capture log changes of databases (such as MySQL, MongoDB, and PostgreSQL) into Pulsar.

CDC source connectors are built on top of Canal and Debezium and store all data into Pulsar cluster in a persistent, replicated, and partitioned way.

Currently, Pulsar has the following CDC connectors.

NameJava Class
Canal source connectororg.apache.pulsar.io.canal.CanalStringSource.java
Debezium source connectororg.apache.pulsar.io.debezium.DebeziumSource.java
org.apache.pulsar.io.debezium.mysql.DebeziumMysqlSource.java
org.apache.pulsar.io.debezium.postgres.DebeziumPostgresSource.java

For more information about Canal and Debezium, see the information below.

SubjectReference
How to use Canal source connector with MySQLCanal guide
How does Canal workCanal tutorial
How to use Debezium source connector with MySQLDebezium guide
How does Debezium workDebezium tutorial