Neo4j Kafka Source configuration for initial load

Integrations Stream Processing
1

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 Kafka Connect Neo4j Connector User Guide - Neo4j Kafka Integration Docs , CDC events are triggered and messages are posted only after the Node data changes. How about loading existing data to topics?

Thanks,

2

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