Investigate the possibility of having multiple instances of AbstractInputFlowlet. That might mean multiple Flowlet instances or multiple data ingestion endpoints.