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.

Name	Java Class
Canal source connector	org.apache.pulsar.io.canal.CanalStringSource.java
Debezium source connector	org.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.

Subject	Reference
How to use Canal source connector with MySQL	Canal guide
How does Canal work	Canal tutorial
How to use Debezium source connector with MySQL	Debezium guide
How does Debezium work	Debezium tutorial