Real-Time ML Feature Engineering Pipeline

A production-grade streaming pipeline built with Apache Kafka and PyFlink. It performs complex event-time processing, stateful windowing, and serves ML features to a real-time WebSocket dashboard via FastAPI.