配置源连接器

在本章中,我们将讨论如何配置 Source 实例。

策略

Source 连接器可以使用两种不同的策略来检测更改并将它们发布为 Kafka 消息

变更数据捕获

使用数据库的 变更数据捕获 功能实时跟踪对数据库发生的所有更改。

查询

运行用户定义的 Cypher 查询来跟踪特定更改。

Source 连接器始终生成具有模式支持的消息,因此您需要相应地使用键和值转换器。