Real-Time Stock Price Stream Processor

Project roadmap

1. 01

   Simulate a tick-data source

   ~2h

   Build a source that emits randomized stock price ticks for multiple symbols at a configurable rate.

2. 02

   Build the streaming graph

   ~2.5h

   Compose Akka Streams stages to route ticks per symbol with proper backpressure.

3. 03

   Implement rolling window aggregation

   ~3h

   Compute rolling moving averages and volatility using sliding windows per symbol.

4. 04

   Implement anomaly detection

   ~2.5h

   Flag ticks that deviate significantly from the rolling average as anomalies.

5. 05

   Expose live results via HTTP

   ~2.5h

   Add an Akka HTTP endpoint that streams current aggregates as server-sent events.

6. 06

   Load test the pipeline

   ~2h

   Measure throughput and latency under high tick volume and tune buffer sizes.

Resources

• DocsScala Documentation