配置源连接器

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

策略

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

变更数据捕获

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

查询

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

源连接器始终生成支持模式的消息,因此您需要相应地使用键和值转换器。
© . All rights reserved.