da231o-data-conduits

A scalable real-time movie recommendation engine using Kafka, Spark Streaming, and Redis. Streams 20M+ MovieLens ratings, updates co-occurrence models incrementally, and serves low-latency personalized recommendations.