# Neo4j Kafka Source configuration for initial load

**URL:** https://community.neo4j.com/t/neo4j-kafka-source-configuration-for-initial-load/27937
**Category:** Streaming (Kafka, Spark, Flink)
**Created:** [October 27, 2020, 7:50am UTC](https://community.neo4j.com/t/neo4j-kafka-source-configuration-for-initial-load/27937 "2020-10-27T07:50:25Z")
**Posts on this page:** 2
**Page:** 1

<div class="post-metadata">

### Author: ![basavarajdhanashetti](https://sea1.discourse-cdn.com/flex021/user_avatar/community.neo4j.com/basavarajdhanashetti/32/14677_2.png) [@basavarajdhanashetti](https://community.neo4j.com/u/basavarajdhanashetti)
#### Post date: [October 27, 2020, 7:50am UTC](https://community.neo4j.com/t/neo4j-kafka-source-configuration-for-initial-load/27937/1 "2020-10-27T07:50:25Z")

</div>

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](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,

---

<div class="post-metadata">

### Author: ![david\_allen](https://sea1.discourse-cdn.com/flex021/user_avatar/community.neo4j.com/david_allen/32/13090_2.png) [@david\_allen](https://community.neo4j.com/u/david_allen)
#### Post date: [October 27, 2020, 11:29am UTC](https://community.neo4j.com/t/neo4j-kafka-source-configuration-for-initial-load/27937/2 "2020-10-27T11:29:13Z")

</div>

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:

```auto
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