如何在Neo4j社区版中使用Kafka

Question

我安装了Neo4j，可以访问服务器。我可以通过密码使节点。现在，我想将其用于数据流。但是我不确定该怎么做。我刚开始Neo4j，并且正在努力安装“ Stream Plugin”。非常感谢您的帮助。

Answer 1

您应该将Neo4j stream插件的jar files直接复制到/plugins文件夹中，并按照here的说明在neo4j.conf文件中配置与Kafka和Zookeeper的连接以及其他Neo4j属性值。例如：

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上的更多内容>