How would you design a data pipeline to ingest, validate, and process millions of meter readings in near real time?
