# Kafka Neo4j Connector Source, how to capture deletes?

**URL:** https://community.neo4j.com/t/kafka-neo4j-connector-source-how-to-capture-deletes/61789
**Category:** Streaming (Kafka, Spark, Flink)
**Tags:** kafka
**Created:** [March 31, 2023, 2:58pm UTC](https://community.neo4j.com/t/kafka-neo4j-connector-source-how-to-capture-deletes/61789 "2023-03-31T14:58:40Z")
**Posts on this page:** 3
**Page:** 1

<div class="post-metadata">

### Author: ![dimitri1](https://avatars.discourse-cdn.com/v4/letter/d/9de0a6/32.png) [@dimitri1](https://community.neo4j.com/u/dimitri1)
#### Post date: [March 31, 2023, 2:58pm UTC](https://community.neo4j.com/t/kafka-neo4j-connector-source-how-to-capture-deletes/61789/1 "2023-03-31T14:58:40Z")

</div>

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

---

<div class="post-metadata">

### Author: ![michael.hunger](https://sea1.discourse-cdn.com/flex021/user_avatar/community.neo4j.com/michael.hunger/32/27377_2.png) [@michael.hunger](https://community.neo4j.com/u/michael.hunger)
#### Post date: [April 4, 2023, 11:58pm UTC](https://community.neo4j.com/t/kafka-neo4j-connector-source-how-to-capture-deletes/61789/2 "2023-04-04T23:58:46Z")

</div>

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

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

---

<div class="post-metadata">

### Author: ![dimitri1](https://avatars.discourse-cdn.com/v4/letter/d/9de0a6/32.png) [@dimitri1](https://community.neo4j.com/u/dimitri1)
#### Post date: [April 13, 2023, 1:31pm UTC](https://community.neo4j.com/t/kafka-neo4j-connector-source-how-to-capture-deletes/61789/3 "2023-04-13T13:31:13Z")

</div>

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