В предыдущей статье мы построили статичный граф цепочки поставок в Neo4j с помощью Apache Spark, связав поставщиков, склады, распределительные центры и розничных продавцов маршрутами доставки. Это дало нам снимок сети в определенный момент времени.В этой статье мы добавим потоковый слой: события отгрузки в реальном времени проходят через Confluent Cloud Kafka, попадают в Neo4j в виде обогащенных свойств графа, а на интерактивной панели отображается состояние сети, обновляющееся по мере поступления событий.