CDC source connector 获取数据库（如：MySQL、MongoDB、PostgreSQL 等）的日志更改并存储在 Pulsar 中。

CDC source connector 基于 Canal 和 Debezium，以持久的、可复制和分区的方式将所有数据存储到 Pulsar 集群中。

目前，Pulsar 有以下 CDC source connector。

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

  了解更多关于 Canal 和 Debezium 的信息，可参考以下内容。

  主题 | 参考链接 |—-|—- 如何在 MySQL 中使用 Canal source connector |Canal guide Canal 使用教程 | Canal tutorial 如何在 MySQL 中使用 Debezium source connector | Debezium guide Debezium 使用教程 | Debezium tutorial