An actor based content ingestion pipeline