Sorry, I meant to say that you have to enrich the original file with a correlation attribute, otherwise there is nothing to correlate on. I am not sure if NiFi has any implementation of ContentEnricher (EIP), perhaps UpdateAttribute will do the trick.
Oleg > On Oct 13, 2015, at 8:21 AM, yejug <[email protected]> wrote: > > Hi Oleg > > THanks for response, may be I missing something (I cannot find you image > =)), but you suggestion doesn;t appropriate. > > There into MergeContent processor brings two types of flowFiles : > 1) one is flow file with original content (AVRO) but without populated > "correlation" attribute, directly from GetKafka > 2) and second type of flow file with parsed content (JSON) and populated > "correlation" attribute > > > > > -- > View this message in context: > http://apache-nifi-developer-list.39713.n7.nabble.com/Ingest-Original-data-from-External-system-by-data-s-dependent-condition-tp3093p3096.html > Sent from the Apache NiFi Developer List mailing list archive at Nabble.com. >
