S

stream-processing

Distributed streaming data platform for exploring event-driven architecture, Kafka, Spark Structured Streaming, reliability, and data-platform engineering.

High-throughput asynchronous ETL and stream processing pipeline in Python

Real-time connected vehicle telemetry pipeline using Kafka, MongoDB, FastAPI, and Grafana with anomaly detection and fleet monitoring dashboards.