Member since
10-16-2019
6
Posts
0
Kudos Received
0
Solutions
03-22-2020
05:39 PM
Hi Guys
I need to know the following, thanks in advance:
i) Do List processors w/ timestamp tracking store state locally?
ii) Does this state survive NiFi restarts?
iii) If running on primary node only, would this mean when another primary node is chosen, the List processor would list any files it hasn't tracked (and re-ingress a large backlog of files if still there)?
iv) What out-of-box solutions can help to get around the issue of non-persisted non-distributed listing, or do we need custom auditing triggering individual listings?
... View more
Labels:
- Labels:
-
Apache NiFi
03-04-2020
05:36 PM
Thanks Matt for explaining this and confirming best practices re x-flow comms. Big help. When less-time sensitive ops and just sending metadata, would you suggest publishing / consuming Kafka? Could be used for triggering dependant flows, reading to an audit table and alerting.
... View more
03-03-2020
07:40 PM
Hi Matt, Thanks for your response, it makes sense. 1.10 seems cool yet may take some time to get productionised for us. Perhaps having 1 POSTHttp for each node and round-robinning could work, but only if we assume that the nodes are fixed. Or, is there a way to query available nodes within NiFi, so can set ${hostname} dynamically? -- Dom
... View more
03-01-2020
10:25 PM
Hey Guys,
Need to establish links between dependent flows within the same NiFi cluster / canvas - e.g. one flow finishes ETL, triggering another flow to begin its ETL on the result of the first's.
From what I gather this could be achieved in 3 ways:
1. Direct connections between flows - undesirable in our production environment and data governance and a spider's web of dependencies
2. Remote processor groups (RPGs) - if can send / receive from same NiFi Cluster
3. HTTP
Could you please advise on options 2 & 3 as a solution for this? RPGs seem simpler than handling HTTP requests / responses yet require an input port on the top level of the flow, which would then need to be directly connected into each flow (being another version of option 1).
Thanks
... View more
Labels:
- Labels:
-
Apache NiFi