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 和 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。