Trades per second, last 3 minutes
Exchange timestamp to processor, milliseconds
Aggregated from one-second tumbling windows, keyed by symbol
| Symbol | Price | Change | VWAP | Volume | Notional | Trades | Buy / sell pressure | Trend |
|---|---|---|---|---|---|---|---|---|
| Waiting for the first window… | ||||||||
Every hop is a separate deployment in the stream namespace
Topics crypto.trades → crypto.metrics, dead letters to
crypto.trades.dlq. Broker kafka.kafka.svc.cluster.local:9092 over SASL/PLAIN.
Prometheus metrics on /metrics of each service; raw snapshot at /api/snapshot.