Kafka Neo4j Connector Source, how to capture deletes?

Integrations & Ecosystem Streaming (Kafka, Spark, Flint)
1

Hi,

I need to capture all the changes in the neo4j database and stream it through Kafka. Neo4j Stream is deprecated and the documentation refers to the Neo4j Connector. Now instead of changes being being pushed, Kafka needs to poll the database using a query. What I can't figure out is how to poll for deletes?

Thanks

2

I think it go undeprecated. So you can still use it.

I guess you'd have to use soft-deletes otherwise.

3

Thanks for your reply. Do you know of a timeline where we can expect Neo4J Stream to go undeprecated?

I'm currently testing having apoc.trigger perform a apoc.load.JsonParams to the Kafka REST proxy to generate an event on a topic. Do you see any drawbacks with this approach?

Thanks