real-time event ingestion