Observe number of concurrent record ingests