Confluent Cloud

配置与 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 提供的值。

© . All rights reserved.