项目概述
|
Kafka Connect Neo4j 连接器是将 Kafka 与 Neo4j 集成的推荐方法，因为 Neo4j Streams 不再处于积极开发阶段，并且在 Neo4j 4.4 版之后将不再支持。 可以在此处找到 Kafka Connect Neo4j 连接器的最新版本。 |
许多用户和客户希望将 Kafka 和其他流式解决方案与 Neo4j 集成。无论是从其他来源将数据导入图中。还是将更新事件（更改数据捕获 - CDC）发送到事件日志以供以后使用。
此扩展旨在满足所有这些用例以及更多即将推出的用例。
Neo4j Streams 作为 Neo4j 插件运行
-
Neo4j Streams 源：一个事务事件处理程序事件，将数据发送到 Kafka 主题
-
Neo4j Streams 接收器：一个 Neo4j 应用程序，通过模板化的 Cypher 语句将数据从 Kafka 主题导入 Neo4j
-
Neo4j Streams 过程：两个过程
streams.publish，允许从 Neo4j 到已配置环境的自定义消息流，以及streams.consume，允许从给定主题消费消息。