code: void readSingleBatch() throws IOException {
          try (final JsonInput jsonInput = openJsonInput()) {
              final JsonParser jsonParser = jsonInput.getJsonParser();
              readBatch(jsonParser);
          } catch (IOException e) {
              metricsCollector.markErrorWhileConsuming();
              throw e;
          }
      }
docs: /*
  @VisibleForTesting