Привет,
В моем потоке NiFi я получаю сообщение в форме сегментов сообщения, но эти сегменты не принимаются в одно и то же время, иногда для сегментов сообщения, связанных друг с другом, требуется 2-4 часа для входа в поток NiFi, мне нужно хранить / хранить эти сегменты в каком-то месте (Kafka или в NiFi Internal Queue или любом другом решении) и время от времени выполнять запрос к ним, чтобы проверить, все ли сегменты, относящиеся друг к другу, получены с использованием идентификатора сегмента (группировать по идентификатору сегмента ), который одинаков для всех сегментов, связанных с исходным сообщением, и объединяет их для создания исходного сообщения с использованием NiFi.
Какое наилучшее масштабное решение для достижения этой цели.