Real-time event ingestion
Workflow steps
| Number | Source | Destination | Description |
|---|---|---|---|
| 1 | Event bus | Kafka consumer | Domain event |
| 2 | Kafka consumer | Stream pipeline | Route to pipeline |
| 3 | Stream pipeline | Window aggregator | Aggregate window |
| 4 | Window aggregator | Query engine | Materialize view |
| 5 | Query engine | Dashboard | Push live update |