开发 Neo4j Streams Kafka Connect Neo4j Connector 是将 Kafka 与 Neo4j 集成的推荐方法,因为 Neo4j Streams 已经不再积极开发,并且在 Neo4j 4.4 版本之后将不再提供支持。 Kafka Connect Neo4j Connector 的最新版本可以从 这里找到。 在本地构建 mvn clean install 将 <project_dir>/target/neo4j-streams-<VERSION>.jar 复制到 $NEO4J_HOME/plugins 中 重新启动 Neo4j 使用 Confluent Platform 和 Kafka Connect Datagen 的示例 Neo4j Streams 常见问题解答