Hello, I need to capture changes from a MySQL database and stream it to a Neo4j db through Kafka. I already have the CDC connector for MySQL but I’m having trouble with the Neo4j sink connector. I’m using the recommended Cypher Strategy from this article but I can’t figure out how to specify the deletion query since it only admits one query
This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.