fixed ingestion to cope with records ingested in parallel at the same time