Configuring sink connector
In this chapter we’ll discuss how the Sink instance is configured.
Strategies
The Sink connector can use different strategies to write Kafka messages into a Neo4j database:
- Cypher
-
Use the incoming Kafka messages as parameters of a user-provided Cypher write query.
- Change Data Capture
-
Process incoming Kafka messages generated by either a Source instance configured with Change Data Capture strategy or the deprecated Neo4j Streams plugin, then apply the changes directly to the target database.
- Pattern
-
Use a Cypher-like pattern syntax to transform incoming Kafka messages into Cypher write queries.
- Create Update Delete (CUD) File
-
Transform incoming CUD-formatted messages into Cypher write queries.