第 1 章 Debezium 简介
Debezium 是一个分布式平台,它将现有数据库的信息转换为事件流,使应用程序能够检测,并立即响应数据库中的行级更改。
Debezium 基于 Apache Kafka 构建,提供一组 Kafka Connect 兼容连接器。每个连接器都可用于特定的数据库管理系统(DBMS)。连接器记录 DBMS 中数据更改的历史记录,方法是在发生时检测更改,并将每个更改事件的记录流传输到 Kafka 主题。然后,消耗应用程序可以从 Kafka 主题中读取生成的事件记录。
通过利用 Kafka 的可靠流平台,Debezium 使应用程序可以正确、完全消耗数据库中发生的更改。即使您的应用程序意外停止或丢失其连接,也不会丢失停机期间发生的事件。应用程序重启后,它会从其离开的时间从主题中恢复读取。
以下教程演示了如何在简单的配置中安装和使用 Debezium MySQL 连接器。有关安装和使用 Debezium 连接器的更多信息,请参阅连接器文档。