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.