Я использую NiFi 1.8 версию, и у моего потока ConsumeKafkaRecord, а затем сразу после этого wait processor. Проблема, которую я вижу здесь, заключается в том, что для 20 МБ создается 10000 flowfiles, что является пределом на данный момент, и очередь застревает на некоторое время и истекает после Expiration parameter. Как мне increase the size of a single flowfile, чтобы я не нажал 10000 и не застрял в очереди? Или есть лучший способ разработать это?
Любые предложения / рекомендации будут высоко оценены.
Вот конфигурации: 
