配置 sink 连接器

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

策略

Sink 连接器可以使用不同的策略将 Kafka 消息写入 Neo4j 数据库。

Cypher

将接收的 Kafka 消息作为用户提供的 Cypher 写入查询的参数。

变更数据捕获 (CDC)

处理由以下两种方式生成的传入 Kafka 消息:使用 变更数据捕获(Change Data Capture)策略 配置的 Source 实例,或已弃用的 Neo4j Streams 插件,随后将更改直接应用到目标数据库。

Pattern (模式)

使用类似 Cypher 的模式语法将传入的 Kafka 消息转换为 Cypher 写入查询。

创建更新删除(CUD)文件

将传入的 CUD 格式消息转换为 Cypher 写入查询。