Pull-based ingestion

Pull-based Ingestion API Introduced 3.0