Before, I was using the neo4j stream to detect change and write it to the Kafka topic, the format is great, it has the before
and after
format, so in there, we can detect if the record is being deleted or not.
However, it is not supported anymore from Neo4J version 4.4 onward, so I switched to Kafka Source connector instead. The problem is, the source connect detect record change by using your own with $lastcheck
parameter, it is great for create/update, but I am not sure if we are able to detect the deletion case.
Guide I've used: Source Configuration - Neo4j Kafka Integration Docs