如何在 Neo4j 社区版中使用 Kafka答案

【问题标题】：How to use Kafka with Neo4j community edition如何在 Neo4j 社区版中使用 Kafka
【发布时间】：2020-05-15 15:03:46
【问题描述】：

我安装了 Neo4j 并且可以访问服务器。我可以通过密码制作节点。现在我想将它用于数据流。但我不知道该怎么做。我刚开始 Neo4j，我正在努力安装“流插件”。非常感谢任何帮助。

【问题讨论】：

标签： plugins neo4j apache-kafka stream

【解决方案1】：

您应该将 Neo4j 流插件的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

【讨论】：

非常感谢您的回复。我在 Ubuntu 16.0 中下载了 Neo4j 桌面。然后我找到了插件文件夹（类似于：/home/brahmanacsw/.config/Neo4j Desktop/Application/neo4jDatabases/database-eef1b9be-5bc1-4237-a5db-23feb465e989/installation-4.0.3/plugins）然后我复制了 . jar (neo4j-streams-4.0.1.jar) 文件。我必须安装 .jar 文件吗？我在 neo4j-streams-4.0.1.jar 中找不到名为“neo4j.conf”的文件。请帮帮我。
不客气。 neo4j.conf 文件可能位于目录“/etc/neo4j/”或您的“/home/brahmanacsw/.config/Neo4j Desktop/Application/neo4jDatabases/database-eef1b9be-5bc1-4237-a5db-23feb465e989/installation- 4.0.3/".
我更改了 .config 文件。但我收到了这些错误。 2020-05-19 04:10:52.004+0000 INFO [neo4j] 初始化 Kafka 连接器 2020-05-19 04:12:52.658+0000 错误 [neo4j] 初始化流生产者时出错：org.apache.kafka.common.errors .TimeoutException：等待节点分配超时 2020-05-19 04:12:52.733+0000 INFO [neo4j] 启动 Kafka Sink 2020-05-19 04:14:53.035+0000 错误 [neo4j] 初始化流式传输时出错水槽：