Debezium简介
Debezium是一个用于变更数据捕获的开源分布式平台。
启动它,将其指向您的数据库,您的应用程序可以开始响应其他应用程序提交到您的数据库的所有插入,更新和删除。Debezium耐用且快速,因此您的应用可以快速响应,即使出现问题也不会错过任何事件。
它是一种CDC(Change Data Capture)工具,通过抽取数据库日志来获取变更。
Debezium构建在Apache Kafka之上,并提供Kafka连接器来监视特定的数据库管理系统。
特点:
- 简单,容易上手
- 快速稳定,构建于Kafka之上,可扩展,经官方验证可处理大容量的数据
- 能监控多种数据库,目前支持的数据库包括MySQL、Oracle、SQL Server等等
架构:
- 基于Kafka Connector 部署 Debezium
- 使用Debezium Server 部署 Debezium
- 嵌入式引擎:内置到其他应用中,如 Flink CDC
使用Debezium连接SQL Server数据库
首先我们要开启SQL Server的CDC功能,开启后下载连接器,解压后进行配置信息,最后注册连接器