Neo4j Streaming Data Integrations
This project integrates Neo4j with streaming data solutions.
Currently it provides an integration with Apache Kafka and the Confluent Platform.
The project contains these components:
Neo4j Kafka Connect Neo4j Connector
A Kafka Connect Sink plugin that allows to ingest events from Kafka to Neo4j via templated Cypher statements. (docs, article)
Documentation & Articles
Read more at https://neo4j.com/docs/kafka/
Here are articles, introducing the Neo4j Extension and the Kafka Connect Neo4j Connector.
And practical applications of the extension for Building Data Pipelines with Kafka, Spark, Neo4j & Zeppelin (part 2).
And for exchanging results of Neo4j Graph Algorithms within a Neo4j Cluster.
Feedback & Suggestions
Please raise issues on GitHub, we also love contributions, so donโt be shy to send a Pull Request.
We would also love you to fill out our survey to learn more about your Kafka + Neo4j use-cases and deployments.
Development & Contributions
Build locally
mvn clean install
Youโll find the build artifact in <project_dir>/target/neo4j-streams-<VERSION>.jar
Testing the Kafka Connect Neo4j Connector locally with Docker.
Docs
The documentation source for this version lives at this repository. Please raise any documentation updates by creating a PR against it.
License
Neo4j Streams is licensed under the terms of the Apache License, version 2.0. See LICENSE for more details.