                 expiredRecords.add(flowFile);                     bytesPulled += flowFile.getSize();                     flowFilesPulled++;                      if (expiredRecords.size() >= MAX_EXPIRED_RECORDS_PER_ITERATION) {                         break;                     } else {                         continue;                     }                 } else if (