Технически вы можете вставить процессор UpdateAttribute после каждого «рабочего» процессора, который бы добавил атрибут, содержащий самый последний процессор, но @Bryan прав, что существует функция провенанса, позволяющая автоматически предоставлять эту информацию. Если вам нужно работать с ним, вы можете использовать SiteToSiteProvenanceReportingTask для отправки этих данных в Удаленную группу процессов (связанную с входным портом на тот же случай), а затем обрабатывать эти данные как любые другие в NiFi и проверять / преобразовывать их.