Real-time ingestion