Относитесь только к первому элементу запроса [duplicate]

public class CountMaxFlatFileItemReader extends FlatFileItemReader {

    private int counter;

    private int maxCount;

    public void setMaxCount(int maxCount) {
        this.maxCount = maxCount;
    }

    @Override
    public Object read() throws Exception {
        counter++;
        if (counter >= maxCount) {
            return null; // this will stop reading
        }
        return super.read();
    }
}

Что-то вроде этого должно работать. Читатель перестает читать, как только возвращается null.

Лучшим соглашением является запись делегата, который отвечает за отслеживание количества прочитанных записей и прекращение после фиксированного счета; компоненты должны позаботиться о контексте выполнения, чтобы обеспечить перезапуск

class CountMaxReader<T> implements ItemReader<T>,ItemStream
{
  private int count = 0;
  private int max = 0;
  private ItemReader<T> delegate;

  T read() {
    T next = null;
    if(count < max) {
      next = delegate.read();
      ++count;
    }
    return next;
  }

  void open(ExecutionContext executionContext) {
    ((ItemStream)delegate).open(executionContext);
    count = executionContext.getInt('count', 0);
  }

  void close() {
    ((ItemStream)delegate).close(executionContext);
  }

  void update(ExecutionContext executionContext) {
    ((ItemStream)delegate).update(executionContext);
    executionContext.putInt('count', count);
  }
}

Это работает с любым читателем.

Для FlatFileItemReader, а также любого другого ItemReader, который продолжается AbstractItemCountingItemStreamItemReader, существует свойство maxItemCount. Путем настройки этого свойства ItemReader будет продолжать считываться до тех пор, пока не будет выполнено одно из следующих условий:

1. Вход был исчерпан.
2. Количество чтение элементов равно maxItemCount.

В любом из двух указанных выше условий нуль будет возвращен читателем, указывая на Spring Batch, что вход завершен.

Если у вас есть какие-либо пользовательские реализации ItemReader, которые должны удовлетворять этому требованию, я бы рекомендовал расширить AbstractItemCountingItemStreamItemReader и перейти оттуда.