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