第 1 章 Debezium 简介

Debezium 是一个分布式平台,将来自您现有数据库的信息转换为事件流,支持应用程序检测,并可立即响应数据库中的行级更改。

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

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

下面的教程显示了如何通过简单的配置部署和使用 Debezium MySQL 连接器。有关部署和使用 Debezium 连接器的详情,请查看连接器文档。