Real-time event ingestion