Условие
Необходимо передать данные из некоторого источника некоторому потребителю. Источник отдает данные небольшими пачками (десятки записей), а потребитель оптимальнее работает с крупными батчами (тысячи записей). Реальный пример — поставка данных из очередей типа Kafka в базу Clickhouse.
Источник
- Условно бесконечный.
- Никогда не возвращает более MaxItems записей за один вызов Next.
- В рамках одной сессии (одного…