Neo4j Kafka Source configuration for initial load

[basavarajdhanas]

Hi,

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

Thanks,

[david_allen]

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(p.name) as personNames
CALL streams.publish('people', personNames)

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