如何通过neo4j-stream向kafka发送节点集合

Question

我们想使用Neo4J构建（产品）类别的层次结构（树结构）。我们的数据从Kafka（接收器连接器）输入。我们计划使用neo4j-4.0.3，使用Neo4J Streams Source将类别树上的更新实时流回到Kafka。

通常，-Streams Source-的方法是指定一种模式并将其链接到Kafka主题，如此处所述：https://neo4j.com/docs/labs/neo4j-streams/current/#neo4j_streams_source

为了利用Neo4J的功能，我们想每次一次]发送一组节点。该集合由-查询中的所有节点组成，该查询返回-路径：nodes(path)。更具体地说，这样的节点集合表示从叶到根的路径。

我们可以想到的两个无效的选择：

1. 使用模式定义。根据我的理解，模式似乎仅限于匹配单个节点（可能是具有多个Label的节点）-https://neo4j.com/docs/labs/neo4j-streams/current/#source-patterns-因此，我们只能流式传输one节点一次。
2. 将节点集合的流（在路径上）返回进入节点
，并使用不同的标签，并使用该输出节点标签对{*}进行模式匹配。 Neo4J是一个面向属性的图形数据库，它不允许我将“节点集合”写入一个节点。

总而言之，我们想要将节点集合流式传输到每个Kafka记录中。关于如何实现此目标的任何建议？

我们想使用Neo4J构建（产品）类别的层次结构（树结构）。我们的数据从Kafka（接收器连接器）输入。我们计划使用Neo4J Streams Source在我们的...

Answer 1

streams.publish procedure将发送您可以用Cypher格式化的任意数据到您选择的主题。您可以根据需要自行设置数据格式。

我正在想象这样的事情：