the loop in acquireMessages will only release the newly read records if: 1. no new data is emitted by audit (2 seconds timeout in poll()) OR 2. read buffer is full