Neo4j Kafka Source configuration for initial load


I was looking for configuration for the Neo4j in conf.ini file to load the existing data onto the Kafka topic.
With configuration provided , CDC events are triggered and messages are posted only after the Node data changes. How about loading existing data to topics?


If you want to send anything that's already in Neo4j to Kafka, you should use the procedures documented there like CALL streams.publish('topic', message)

For example, you could do this:

MATCH (p:Person)
WITH collect( as personNames
CALL streams.publish('people', personNames)

And you'd get a JSON array of strings sent to that topic