Neo4j Kafka 连接器

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

该连接器提供两个版本

适用于 Confluent Platform® 和 Confluent Cloud® 的Neo4j Connector for Confluent可用。
适用于基于开源软件 (OSS) Apache Kafka® 构建的平台（包括 Amazon MSK®）的Neo4j Connector for Apache Kafka可用。

组件

Sink（接收器）

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

Source（源）

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

Change Data Capture（变更数据捕获）是 Neo4j 5.13.0 和 Aura 5 引入的新功能，具备 CDC 支持的 Source 连接器至少需要这些版本的 Neo4j 和 Aura。

兼容性

Neo4j 兼容性

该连接器支持 Neo4j 2025.x 和 5.x，无论是作为受管服务在Neo4j Aura中运行，还是单实例或集群部署。它同时支持 Community 版和 Enterprise 版。

某些功能（如约束和 CDC）仅在 Neo4j Enterprise 版或 AuraDB Enterprise 中可用，在 Neo4j Community 版以及 AuraDB 的 Free 和 Professional 级别中不可用。

Kafka Connect 兼容性

该连接器旨在兼容 Apache Kafka Connect 3.4.1 及更高版本。这包括在 Confluent Platform 与 Cloud 上的 Amazon MSK 以及 Confluent Connect 7.4 及更高版本。

Java 兼容性

该连接器使用 Java 11 构建，兼容在 Java 11 以及 Java 的 LTS 版本（如 17 和 21）上运行。

许可证

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

支持

对于 Neo4j Enterprise 与 Neo4j AuraDB 客户，依据您现有的 Neo4j 支持协议，部署到 Confluent Platform、Confluent Cloud、Apache Kafka 与 Amazon MSK 的官方发布版本均受支持。此支持仅限于正式发行版，不包括 alpha、beta 与预发布版。如有关于支持政策的疑问，请联系 Neo4j。