Я новичок в nifi (используется версия 1.8.0). У меня есть требование потреблять сообщения кафки, которые содержат позицию транспортного средства в форме широты, долготы за сообщение. Поскольку каждое сообщение будет поступать в виде файла потока, мне нужно объединить все эти файлы потока и создать файл json, содержащий полный путь, по которому следует транспортное средство. Я использую процессор потребителя kafka для подписки на сообщения, обновляю процессор атрибутов (добавлены следующие свойства: filename: $ {getStateValue ("seq")}, seq: $ {getStateValue ("seq"): plus (1)}) для добавления порядковый номер в качестве имени файла (например, имя файла равно 1,2, 3 и т. д.) и поместите файловый процессор для записи этих файлов в указанный каталог. Я настроил очередь приоритетов FIFO для всех успешных отношений между вышеупомянутыми процессорами. Однажды я получил все сообщения, которые хочу объединить со всеми файлами потоков. Для этого я знаю, что мне нужно использовать get file, установить порядок, объединить содержимое (стратегия объединения: алгоритм упаковки бинов, формат объединения: двоичная конкатенация) и обработчик файлов put соответственно. Мой подход правильный? Как мне установить, что объединение файлов происходит в последовательности их имен, так как имя файла - это следующий номер. Что я должен поставить в атрибуте порядка в принудительном порядке обработчик? Что следует добавить в идентификатор группы? Можно ли добавить дополнительные настраиваемые поля в обработчик принудительного порядка?