Neo4j Streaming Data Integrations

This project integrates Neo4j with streaming data solutions. Currently it provides an integration with Apache Kafka and the Confluent Platform.

Description

The project is composed of these parts:

• Neo4j Kafka Connector: a Kafka Connect plugin that allows to ingest events from Kafka to Neo4j via templated Cypher statements

• Neo4j Extension:

  • Neo4j Streams Producer (Source): a transaction event handler events that sends data to a Kafka topic

  • Neo4j Streams Consumer (Sink): a Neo4j application that ingest data from Kafka topics into Neo4j via templated Cypher statements

• Neo4j Streams Procedures (Read & Write): Procedures to write to and read from topics interactively/programmatically

Installation

1. Download the jar-file from the latest release

2. Copy neo4j-streams-<VERSION>.jar into $NEO4J_HOME/plugins

3. Restart Neo4j

Build locally

mvn clean install

You’ll find the build artifact in <project_dir>/target/neo4j-streams-<VERSION>.jar

Documentation Links

Kafka Connect Plugin

Kafka Connect Plugin

Streams Producer

Configuration

Patterns

Streams Consumer

Configuration

Streams Procedures

Procedures

Docker

Docker