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

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

    目前,Pulsar 有以下 CDC source connector。

    Name|Java Class |—-|—- Canal source connector|org.apache.pulsar.io.canal.CanalStringSource.java Debezium source connector|