Simplified low-latency stream ingestion and monitoring - View it on GitHub