如何在 Neo4j 社区版中使用 Kafka

How to use Kafka with Neo4j community edition

我安装了Neo4j,可以访问服务器了。我可以通过密码创建节点。 现在我想将它用于数据流。但我不确定该怎么做。我刚开始使用 Neo4j,我正在努力安装 'Stream Plugin'。 非常感谢任何帮助。

您应该复制 jar files for the Neo4j streams plugin directly into your /plugins folder and configure the connections to Kafka and Zookeeper as well as other Neo4j property values at the neo4j.conf file as described here。例如:

kafka.zookeeper.connect=zookeeper-host:2181
kafka.bootstrap.servers=kafka-host:9092

或者,如果您只想从 Kafka 寻找接收器连接(即将记录从 Kafka 主题移动到 Neo4j),您还可以使用 Kafka Connect 和支持的 Kafka Connect Neo4j Sink。更多内容在 https://www.confluent.io/hub/neo4j/kafka-connect-neo4j