在上一篇文章中，我们使用 Apache Spark 在 Neo4j 中构建了一个静态供应链图谱，其中供应商、仓库、配送中心和零售商通过运输路线相互连接。这为我们提供了某一时间点的网络快照。在本文中，我们将添加流处理层：货运事件实时流经 Confluent Cloud Kafka，作为增强的图谱属性落地到 Neo4j，同时一个实时仪表板会随着事件的到达动态更新网络健康状态。