如何在 Neo4j 中自动匹配从 kafka 发送的事件

我有一些事件从 Kafka 主题发送到现有的 Neo4j 数据库。数据库已经有大约 4000 个标签和 11500 个关系。这些从 kafka 发送的事件应该自动匹配它们对应的节点。让我们说：

有 3 个节点代表产品 a 和产品 b。

kafka 主题将不同产品的状态发布到 neo4j：产品 a：有货，产品 b：已屏蔽：产品 a：已屏蔽，产品 a：已发货

图表应该是：

（产品 A）------>（有货）----->（已屏蔽）---->（已发货）

（产品 B）------>（被屏蔽）

我不知道如何解决这个问题。尽我所能，我可以将事件从 kafka 摄取到 neo4j，但之后我无法将它们与相应的产品相匹配。

非常感谢。