Project 01
Real-Time Fraud Signals Pipeline
Kafka -> Spark Structured Streaming -> Delta -> dbt -> Streamlit. Exactly-once processing, anomaly detection, dbt tests.
Streaming ingestion + watermarks · Data quality / dbt tests · Fraud analytics architecture
~110k/s detector throughput
- Apache Kafka
- Spark Structured Streaming
- Delta Lake
- dbt
- Streamlit