3

In my project I have PostgreSQL database as main DB and I need to keep synchronized my neo4j DB. To do so I want to use Debezium for CDC, kafka and neo4j streams plugin. One of the reasons I prefer Debezium to jdbc is because it's real time. So at this point I want to get

PostgreSQL -> Debezium -> Kafka -> Confluent -> Neo4j

from documentation I found sink Neo4j CDC but only from another Neo4j DB.

Sink ingestion strategies
Change Data Capture Event
This method allows to ingest CDC events coming from another Neo4j Instance.

Why only from another Neo4j instance? I am confused because I don't understand how exactly I should implement Change data Capture from PostgreSQL to neo4j.

Armen Sanoyan
  • 1,898
  • 2
  • 19
  • 32

0 Answers0