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:

  • BOOTSTRAP_SERVER_URL

  • API_KEY

  • API_SECRET

More specifically the plugin has to be configured as follow:

neo4j.conf
kafka.bootstrap.servers=${BOOTSTRAP_SERVER_URL}
kafka.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${API_KEY}" password="${API_SECRET}";
kafka.ssl.endpoint.identification.algorithm=https
kafka.security.protocol=SASL_SSL
kafka.sasl.mechanism=PLAIN
kafka.request.timeout.ms=20000
kafka.retry.backoff.ms=500

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.