Confluent Cloud

The Kafka Connect Neo4j Connector is the recommended method to integrate Kafka with Neo4j, as Neo4j Streams is no longer under active development and will not be supported after version 4.4 of Neo4j.

The most recent version of the Kafka Connect Neo4j Connector can be found here.

Configuring a connection to a Confluent Cloud instance should follow Confluent’s Java Client configuration advice, and the advice in Kafka settings section. At a minimum, to configure this, you will need:




More specifically the plugin has to be configured as follow:

kafka.bootstrap.servers=${BOOTSTRAP_SERVER_URL} required username="${API_KEY}" password="${API_SECRET}";

Make sure to replace BOOTSTRAP_SERVER_URL, API_SECRET, and API_KEY with the values that Confluent Cloud gives you when you generate an API access key.