配置源连接器
在本章节中,我们将讨论如何配置 Source 实例。
策略
Source 连接器可以使用两种不同的策略来检测更改并将其作为 Kafka 消息发布
- 变更数据捕获 (CDC)
-
使用数据库的 变更数据捕获 功能实时跟踪数据库中发生的所有更改。
- 查询
-
运行用户自定义的 Cypher 查询以跟踪特定更改。
| Source 连接器始终生成带有模式支持的消息,因此需要相应地使用键和值转换器。 |
在本章节中,我们将讨论如何配置 Source 实例。
Source 连接器可以使用两种不同的策略来检测更改并将其作为 Kafka 消息发布
使用数据库的 变更数据捕获 功能实时跟踪数据库中发生的所有更改。
运行用户自定义的 Cypher 查询以跟踪特定更改。
| Source 连接器始终生成带有模式支持的消息,因此需要相应地使用键和值转换器。 |