Neo4j Kafka 连接器

Neo4j Kafka 连接器使用 Kafka Connect 框架在 Neo4j 或 Aura 数据库与基于 Apache Kafka® 的平台之间传输数据流。

该连接器分为两个版本

适用于 Confluent 的 Neo4j 连接器可用于 Confluent Platform® 和 Confluent Cloud®。
适用于 Apache Kafka 的 Neo4j 连接器可用于基于开源软件 (OSS) Apache Kafka® 构建的平台，包括 Amazon MSK®。

组件

目标

目标组件从 Apache Kafka 主题消费消息，并将配置的更改应用于 Neo4j 或 Aura 数据库。

源

源组件监听 Neo4j 或 Aura 数据库中发生的更改，并将消息发布到 Apache Kafka 主题。它可以配置为使用数据更改捕获功能或提供的自定义查询来读取更改。

数据更改捕获是 Neo4j 5.13.0 和 Aura 5 中引入的新功能，支持 CDC 的源连接器至少需要这些版本的 Neo4j 和 Aura。

兼容性

Neo4j 兼容性

该连接器支持 Neo4j 5.x 和 4.4，无论是在 Neo4j Aura 中作为托管服务运行，还是作为单个实例或集群运行。它支持社区版和企业版。

某些功能，例如约束和 CDC，仅在 Neo4j 企业版或 AuraDB 企业版中可用，而在 Neo4j 社区版或 AuraDB 的免费和专业层中不可用。

Kafka Connect 兼容性

该连接器设计为与 Apache Kafka Connect 3 及更高版本兼容，包括 Confluent Platform、Confluent Cloud 和 Amazon MSK。

Java 兼容性

该连接器使用 Java 11 构建，并兼容 Java 11 及 LTS 版本（即 17 和 21）的运行环境。

许可证

源代码是根据 Apache 2.0 许可证条款提供的。您可以自由下载、修改和重新分发该连接器；但是，Neo4j 支持仅适用于 Neo4j 提供的官方构建版本。

支持

对于 Neo4j Enterprise 和 Neo4j AuraDB 客户，此连接器部署到 Confluent Platform、Confluent Cloud、Apache Kafka 和 Amazon MSK 的官方版本根据您现有的 Neo4j 支持协议条款提供支持。此支持仅限于常规发布版本，不包括 alpha、beta 和预发布版本。如果您对支持政策有任何疑问，请联系 Neo4j。