Project Overview

The documentation on the deprecated Neo4j Streams plugin and the previous version of the Kafka Connect Neo4j Connector can be found here.

The Neo4j Connector for Apache Kafka and Neo4j Connector for Confluent are designed for customers who want to stream data from distributed event stores and streaming platforms like Apache Kafka ™ into Neo4j or Aura to make decisions in real time.

Both connectors can be used to sink data into Aura and Neo4j from Kafka Topics (ingest), or as a source of updates and new data (change data capture - CDC) for Kafka Topics to be consumed by other systems.

The Neo4j Connector for Confluent runs as a Kafka Connect Plugin on the Confluent Platform and can be deployed into the Confluent Cloud using their Custom Connectors. It is available from the Confluent Hub, or from the Neo4j Download Center.

The Neo4j Connector for Apache Kafka runs as a Kafka Connect Plugin on Apache Kafka and can be deployed into Amazon Managed Streaming for Apache Kafka (Amazon MSK). It is available from the Neo4j Download Center.

Kafka Connect Neo4j Connector

Kafka Connect Neo4j Connector is deployed separately from the Neo4j database. The Connect Worker can be used both to sink data to Neo4j and as a source to publish data from the database itself.

Compatibility between Neo4j and Kafka Connect Neo4j Connector

We recommend using the latest version of Kafka Connect Neo4j Connector to be compatible with all the supported versions of Neo4j.

Support for Kafka Connect Neo4j Connector

The support for Neo4j Connectors deployed into Apache Kafka, Amazon MSK and Confluent is provided by Neo4j.