Real-world production projects.
Not toy tutorials.
Every project in this catalog is designed as a deployable, interview-ready system. Ship it, write it up, talk through it in the hiring loop.
The 3 projects that get you hired.
Flink fraud detection
Stateful streaming pipeline on Flink + Kafka — 5 keyed-state detectors, exactly-once via 2PC, Flink K8s Operator with ZK HA.
Iceberg Lakehouse Foundations
Local ACID lakehouse on Iceberg + Nessie + MinIO. Bronze → Silver → Gold + maintenance.
Enterprise RAG — retrieval-quality build
EXPERT-tier retrieval-quality RAG: 4-strategy chunking A/B (62/78/85%), hybrid BM25 + dense + RRF, cross-encoder reranker, RAGAS 4-metric canary, LLM gateway with fallback. 5 ADRs + cost-model CSV bundled.
The portfolio projects that actually get interviews in 2026.
Every data engineer with a GitHub has “a project.” Most of them are toy ETL pipelines that read a CSV from S3 and write a Parquet file to S3. They don’t survive a senior interview — and they don’t survive an AI-era one. The 30+ projects below are built around what hiring managers at top-tier data teams are actually testing in 2026.
What makes a project interview-ready
Three things separate a portfolio project that earns an on-site from one that gets filtered. One: the project ships a deployable artifact — a Docker Compose stack, a Kubernetes manifest, a Terraform module — not just a Jupyter notebook. Two: the project has measurable outcomes you can defend in an interview (“the hybrid retriever hit recall@10 = 0.92,” “the Spark job dropped from 47min to 5min,” “the Snowflake bill went from $300K to $120K”). Three: the project has an Architecture Decision Record (ADR) explaining the tradeoff — and ideally at least one Deprecated ADR showing a reversal, which is the single strongest signal of real-world experience.
Which project should you build first?
If you’re newer than mid-level, start with the free E-commerce Data Warehouse — Kimball dimensional modeling, dbt staging → intermediate → mart, incremental contracts. It’s the project every interviewer recognises and it’s the cleanest foundation for the others. If you’re an experienced DE moving into AI, start with Enterprise RAG — hybrid BM25 + dense + RRF + cross-encoder reranker, with a 4-strategy chunking A/B benchmark (62% / 78% / 85% accuracy across strategies). If you’re aiming at staff-level, build Flink Fraud Detection — keyed state on RocksDB, exactly-once Kafka via two-phase commit, sub-100ms decision windows. Every one of these is the kind of system an interviewer can ask “what would you do if X failed?” for an hour.
What ships with every project
Each project here is more than a tutorial. It ships with a starter kit (Docker / Postgres / Redis / Spark / dbt stack that actually boots), a runnable cost-model CSV with cited provider list prices, committed ADRs that document the tradeoffs considered, seed data, and a working CI pipeline. Expert projects include 5 ADRs (one Deprecated) and the cost-model bundled in the starter zip. That’s the kind of repo a hiring manager opens, reads the ADRs, and decides to invite you to an on-site without watching a screen-share.
The 7 project tracks
The 30+ projects span 7 tracks mapped to the curriculum: Foundations (warehouse + metrics layer), Batch (ingestion + orchestration), Streaming (Kafka + Flink), Lakehouse (Iceberg + multi-engine), Platform (CI/CD + governance + cost), AI Systems (RAG + agentic + inference serving), and Leadership (the staff-engineer playbook). Filter the catalog below by track, tier (Free / Professional / Expert), and difficulty to find yours.
Each project below shows its track, tier, estimated time-to-ship, and the specific architectures it teaches. Click in to see the full ADR list and what’s in the starter kit before you start.
Foundations
Commerce data warehouse
Kimball star schema with 22 dbt models — atomic + event facts, SCD2 via snapshots, incremental processing, and a GitHub Actions Slim CI gate.
Ecommerce analytics modeling layer
Free 17-model dbt analytics modeling layer for ShopCo — star schema with documented grain, incremental + SCD2, RFM-scored LTV, and a dbt Cloud + Slim CI production spine.
Batch pipelines
Iceberg Lakehouse Foundations
Local ACID lakehouse on Iceberg + Nessie + MinIO. Bronze → Silver → Gold + maintenance.
ShopStream Spark Batch Pipeline
Spark + Delta Lake batch ETL with 4 documented optimization patterns (9x progression), ACID lakehouse, and a Kafka/K8s streaming overlay.
Airflow + dbt: production pipeline foundations
3 production DAGs: REST-API ingestion + idempotent UPSERT, multi-source orchestration with TaskGroups + dynamic mapping, dbt medallion with quality-gated tests. Local Docker.
IceLake Commerce — end-to-end Iceberg tour
Breadth tour: foundations, multi-engine, Debezium+Kafka+Flink CDC, Feast on Iceberg in 13h.
Streaming
Flink fraud detection
Stateful streaming pipeline on Flink + Kafka — 5 keyed-state detectors, exactly-once via 2PC, Flink K8s Operator with ZK HA.
Real-time fraud detection on Kafka Streams
Stateful Kafka Streams topology with KTable enrichment, EOS v2, and Strimzi K8s manifests.
Schema evolution & data contracts
FastAPI schema registry, dbt + Great Expectations enforcement, GitHub Actions PR gate, and column-level lineage with NetworkX + OpenLineage.
Real-time fraud feature store
Feast + Kafka + Spark Streaming spine for a fraud model: 22 features, p99 < 10ms, Schema Registry + Avro, Helm/K8s.
Data quality
Data observability stack
Detect, trace, prevent: dbt + OpenLineage + Grafana on a pre-broken warehouse.
Data governance & contracts
ODCS contracts, GE + Soda validation, Avro + Schema Registry PR gate, 4-tier PII + RBAC + hashed audit, SOC2 + GDPR engines.
AI & vectors
Enterprise RAG — retrieval-quality build
EXPERT-tier retrieval-quality RAG: 4-strategy chunking A/B (62/78/85%), hybrid BM25 + dense + RRF, cross-encoder reranker, RAGAS 4-metric canary, LLM gateway with fallback. 5 ADRs + cost-model CSV bundled.
PredictFlow — production MLOps platform with Feast + BentoML
EXPERT-tier MLOps build: MLflow + DVC + Feast (offline/online), BentoML on K8s with HPA + canary, Evidently drift + cron-gated retrain, Prometheus + Grafana. Modules 01-02 with PRO; full platform with EXPERT.
LLM evaluation framework — multi-judge cascade + recall@k gate
EXPERT-tier eval build: 3-judge cascade (Haiku → Sonnet → GPT-4o), variance-based agreement, recall@k regression gate in GitHub Actions, RAGAS scaffolding, online drift detection, 5 committed ADRs (one Deprecated), runnable cost-model CSV. 7 modules · 17-19h. Module 01 with PRO.
AI cost optimization (CostGuard)
Cost-aware LLM platform: token tracking, dual-tier cache, 4-strategy router, three-tier budget governance. 5 ADRs + cost-model CSV bundled.
Agentic data pipeline — LangGraph supervisor + HITL + ADRs
EXPERT-tier agent platform: LangGraph supervisor + 4 worker agents, RBAC tool registry, Redis checkpointing + 24h time-travel, HITL via interrupt_before + Slack actionable buttons, FailureDetector + ToolCallGuard, multi-tenant platform-design capstone, 5 committed ADRs (one Deprecated), runnable cost-model CSV. 6 modules · 17-18h. Modules 01-03 with PRO.
AI retrieval platform — pgvector + hybrid + RRF + cross-encoder
EXPERT-tier retrieval build: pgvector + HNSW, BM25 + RRF, cross-encoder reranker, OpenAI function-calling agent, semantic cache, drift detection, multi-region replication code. Modules 01-02 with PRO; full platform with EXPERT.
AI serving platform — vLLM + Ray Serve under SLA
EXPERT-tier inference build: vLLM continuous batching + PagedAttention, Ray Serve autoscale (market-hours min=2), Redis semantic cache (35% hit), ServingCircuitBreaker, 5 chaos scenarios + runbook, runnable cost-model CSV with break-even-vs-OpenAI math. Module 01 with PRO.
LLM training-data pipeline — crawl + dedup + RAG + LLMOps
EXPERT-tier dataset-engineering build: aiohttp crawler + MinHash/LSH dedup + quality scoring + tokenizer + pgvector/Pinecone RAG + vLLM serving + Airflow DAGs + Locust load tests + CI eval gate. Modules 01-02 with PRO; full platform with EXPERT.
Enterprise AI platform — multi-tenant governed RAG
EXPERT-tier governance build: pgvector + Postgres RLS, Presidio + jailbreak guardrails, lineage + policy in Redis, per-tenant cost tracker, OTel + Prometheus. 4 modules · 20-26h. Module 01 with PRO.
Platform
CI/CD data platform
Terraform + GitHub Actions + dbt CI — the platform under the platform.
DataGuard reliability
SRE for the data platform: dependency graphs, dep-aware SLOs, chaos engineering, multi-team incident management.
Cloud cost optimization
Cut a $300K Snowflake bill 60% — forensics, right-size, compact, govern.
Multi-source ingestion service
REST + webhook + S3 + SaaS through one Airflow DAG, with backoff, dedup, and schema gates.
Staff Engineering
Uber Event Platform: Staff Design Portfolio
Staff-level system-design portfolio: redesign Uber's event platform, 10K → 1B events/day. 69 artifacts, no code.
Full-stack AI platform — full RAG system + production hardening
EXPERT-tier full-stack RAG: pgvector + HNSW + hybrid retrieval + RRF + cross-encoder rerank, 4-class query router with confidence threshold, 3-level failure cascade (RAG → LLM-only → cached), per-tenant index isolation, eval gates, cost guardrails, 6-mode incident simulator, 5 committed ADRs (one Deprecated), runnable cost-model CSV. 6 modules · 20-22h. Modules 01-03 with PRO.
Multi-cloud platform foundation
Terraform IaC for AWS + GCP: dev/staging/prod, 5-role RBAC, KMS secrets, AWS Budgets + Grafana FinOps.
Experimentation platform on dbt + scipy
Welch + MDE + SRM + scorecard. 26+ dbt models, scipy stats, FastAPI + Redis flag service, lifecycle state machine.
Staff+ leadership playbook
RFC → ADR → architecture review → blameless postmortem. The four artifacts a promo committee actually reads.
Can’t decide which one to start with?
Take the 2-minute skill assessment. We’ll match you to the project that fits your level and the career you’re aiming for.