The Streaming Ingestion framework for ezbake.