配置源连接器

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

策略

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

变更数据捕获 (CDC)

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

查询

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

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