Neo4j Connector for Apache Kafka (Neo4j Streams)

Many user and customers want to integrate Kafka and other streaming solutions with Neo4j, either to ingest data into the graph from other sources or to send update events to the event log for later consumption. Neo4j Streams was developed to satisfy all these use-cases and more to come.

Aura supports the use of the Kafka Connect Plugin, which allows you to ingest data into Neo4j from Kafka topics via Cypher queries.

Connecting to Aura only requires to make a few changes to the source and sink configuration examples:

  • Replace the bolt URI in the examples (the value of the neo4j.server.uri configuration parameter) with the neo4j+s:// connection URI from the Aura instance detail page

  • Update the username and password configuration parameters as appropriate

For more information check the Neo4j Streams page.

Aura currently only supports the Kafka Connect Plugin. Connection via the Neo4j plugin is not supported.