Confluent Cloud

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.