Extensible streaming ingestion pipeline on top of Apache Spark - View it on GitHub