第 2 章 Debezium 简介

Debezium 是一个分布式平台，可将现有数据库中的信息转换为事件流，使应用程序能够检测到，并立即响应数据库中的行级更改。

Debezium 基于 Apache Kafka 构建，提供一组 Kafka 连接兼容连接器。每个连接器都与特定的数据库管理系统(DBMS)一起工作。连接器通过检测更改在 DBMS 中记录数据更改历史记录，并将每个更改事件的记录流传输到 Kafka 主题。然后，消耗应用程序可以从 Kafka 主题读取生成的事件记录。

通过利用 Kafka 的可靠流平台，Debebe 使应用程序能够正确且完全使用数据库中发生的更改。即使您的应用程序意外停止或丢失其连接，也不会丢失中断期间发生的事件。应用程序重启后，它会从其离开的时间点恢复从主题读取。