Confluent Cloud

Kafka Connect Neo4j 连接器是将 Kafka 与 Neo4j 集成的推荐方法，因为 Neo4j Streams 不再处于积极开发中，并且在 Neo4j 4.4 版本之后将不再受支持。

Kafka Connect Neo4j 连接器的最新版本可在此处找到。

配置与 Confluent Cloud 实例的连接应遵循Confluent 的 Java 客户端配置建议，以及Kafka 设置部分中的建议。至少，要配置此项，您将需要

  • BOOTSTRAP_SERVER_URL

  • API_KEY

  • API_SECRET

更具体地说，插件必须按以下方式配置

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

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