Skip to main content
Version: 2.10.0

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