01 · Sources
Map the event producers
Six systems describe different parts of the marketplace.
02 · Contract
Standardize every event with shared metadata
An envelope is a common outer structure around each source-specific payload.
Shared envelope · same for every source
event_idevent_timeingestion_timeentity IDsevent_versiongeohash
Source-specific payload
location_ping | trip_matched | payment_captured | ...Why the shared envelope is necessary
Dedupe + ordersame rules for every producer
Measure delayevent time vs ingestion time
Join + evolvestable keys and versions
03 · Operating model
Volume and priority are different axes
A small stream can demand stronger handling than a large one.
Priority ↓ / Volume →LowMediumHigh
Highest
Support + safety
Payments
Driver GPS
Standard
—
Maps + dispatch
Rider activity
04 · Population
Populate Bronze, Silver, and Gold
Raw device events enter Kafka, Flink enriches them, and trusted facts emerge in stages.
→
→
→
→
05 · Interview insight
Build one trustworthy trip from 5 producers
The same trip is described independently, and events can be late, duplicated, or out of order.