Confluent 云

配置与 Confluent Cloud 实例的连接应遵循 Confluent Java 客户端的配置建议。至少，您需要配置以下内容：

BOOTSTRAP_SERVER_URL
API_KEY
API_SECRET

具体来说，过程必须按照以下方式进行配置：

neo4j.conf

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

请确保将 BOOTSTRAP_SERVER_URL、API_SECRET 和 API_KEY 替换为您在生成 API 访问密钥时 Confluent Cloud 提供的值。