Kafka CDC是可行的，可以用于已经存在的数据库和数据。CDC需要设立一个“源”和一个“目标”来捕获和传输修改。源是数据库，并且支持MySQL、PostgreSQL和Oracle数据库。在源数据库上启用binlog用户参数协议（MySQL），或等效的协议（例如：WAL），以便Kafka能够在不下血本修改数据库的情况下，捕获正在发生的变化。

以下是使用Kafka Connect API和Debezium运行的一个Kafka CDC的范例：

1.将以下代码保存在名为“mysql-connector-sink.properties”的文件中：

使用Debezium MySQL Connector

connector.class=io.debezium.connector.mysql.MySqlConnector tasks.max=1

数据库连接信息

database.hostname=localhost database.port=3306 database.user=mysqluser database.password=mysqldPassword database.server.id=184054 database.server.name=myDB database.whitelist=myDB.inventory,myDB.products database.history.kafka.bootstrap.servers=localhost:9092 database.history.kafka.topic=schema-changes.inventory

2. 运行Debezium connector，需要将配置文件作为参数传递给命令

bin/connect-standalone.sh config/connect-standalone.properties mysql-connector-sink.properties

源数据库的表格和数据将被定期捕获， Kafka connector将在topic中创建多个数据，在这里可用于进一步处理或存储。