Telemetry Ingestion

- High-throughput ingestion: MQTT -> Kafka / Pulsar as buffer - Message format: Protobuf or CBOR for compact payload - Schema validation and evolution (device models with versioned schemas) - Ingestion-side deduplication and ordering by device + sequence number - Backpressure: drop oldest / sample at high load with SLA tiers