配置 Sink 连接器
在本章中，我们将讨论如何配置 Sink 实例。
策略
Sink 连接器可以使用不同的策略将 Kafka 消息写入 Neo4j 数据库。
- Cypher
-
将传入的 Kafka 消息用作用户提供的 Cypher 写入查询的参数。
- 数据变更捕获
-
处理由以下任一方式生成的传入 Kafka 消息：配置了数据变更捕获策略的 Source 实例，或已弃用的Neo4j Streams 插件，然后将更改直接应用到目标数据库。
- 模式
-
使用类似 Cypher 的模式语法将传入的 Kafka 消息转换为 Cypher 写入查询。
- 创建、更新、删除 (CUD) 文件
-
将传入的 CUD 格式消息转换为 Cypher 写入查询。