如何在neo4j社区版中使用kafka

tkqqtvp1  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(569)

我安装了neo4j,可以访问服务器。我可以通过cypher创建节点。现在我想把它用于数据流。但我不知道怎么做。我刚开始neo4j,我正在努力安装'流插件'。非常感谢您的帮助。

a64a0gku

a64a0gku1#

您应该将neo4jstreams插件的jar文件直接复制到 /plugins 文件夹并配置到kafka和zookeeper的连接以及neo4j.conf文件中的其他neo4j属性值,如下所述。例如:

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

或者,如果您只在寻找来自kafka的接收器连接(即,将记录从kafka主题移动到neo4j),也可以将kafka connect与支持的kafka connect neo4j接收器一起使用。更多https://www.confluent.io/hub/neo4j/kafka-connect-neo4j

相关问题