How would you design an end-to-end pipeline to ingest and process real-time telemetry data from enterprise servers?