Open-source data collection engine with real-time pipelining capabilities for ingesting data from various sources.