Real-Time Feature Store
When your model needs low-latency access to fresh features at inference time
A centralized feature store serves precomputed and real-time features to models in production. I design feature pipelines that process batch and streaming data into a unified store, ensuring training-serving consistency and eliminating feature drift.
Architecture Components
Batch Pipeline
Airflow + Polars/DuckDB
Historical feature computation
Streaming Pipeline
Kafka / Pub/Sub + Flink
Real-time feature updates
Feature Store
Redis / Bigtable / Feast
Low-latency feature serving
Registry
MLflow / custom
Feature versioning and lineage
Anti-Patterns I Avoid
- ✗ Computing features in the model serving path (adds latency, creates inconsistency)
- ✗ Using different code for training vs serving features (train-serve skew)
- ✗ Storing features in the model artifact (bloats model, prevents reuse)