docs: private LogRecordWithInputStream nextLogRecord() throws IOException {
      try {
        return nextLogRecord(reader);
      } catch (EndOfStreamException e) {
        eos = true;
        LOG.info(()->"end of stream is reached");
        return null;
      }
    }