Configuring source connector
In this chapter we’ll discuss how the Source instance is configured.
Strategies
The Source connector can use two different strategies to detect changes and publish them as Kafka messages:
- Change Data Capture
-
Uses the database’s Change Data Capture feature to track all changes happening to the database in real time.
- Query
-
Runs a user-defined Cypher query to track specific changes.
The Source connector always generates messages with schema support, so you need to use key and value converters accordingly. |