0
点赞
收藏
分享

微信扫一扫

Debezium架构

梦想家们 2022-01-23 阅读 77

通过Kafka Connect部署Debezium

最常见的是,您通过 Apache Kafka Connect部署 Debezium 。Kafka Connect 是一个用于实现和操作的框架和运行时:

  • source connector(例如 Debezium)将record发送到 Kafka

  • sink connector将record从 Kafka Topic 传播到其他系统

下图显示了基于 Debezium 的CDC管道的架构:

如图所示,部署了用于 MySQL 和 PostgresSQL 的 Debezium 连接器来捕获对这两种类型的数据库的更改。每个 Debezium 连接器都建立到其源数据库的连接:

  • MySQL 连接器使用client library来访问binlog.

  • PostgreSQL 连接器从logical replication stream中读取。

Kafka Connect 作为 Kafka Broker之外的单独服务运行。

默认情况下,来自一个数据库表的更改将写入名称与表名对应的 Kafka Topic。如果需要,您可以通过配置 Debezium 的

举报

相关推荐

0 条评论