Member since
08-02-2023
6
Posts
0
Kudos Received
0
Solutions
08-07-2023
10:13 PM
Hi Kellerj. Thank you for the reply. I will try this approach for my case. Can you please send the sample template for the flow you mentioned?
... View more
08-07-2023
09:46 PM
Hi Matt. The exception I am getting in PublishKafka 2_6 is, PublishKafka_2_6[id=c448b32e-0189-1000-c518-0da7df8acb8a] Processing halted: yielding [1 sec]: org.apache.kafka.common.errors.TimeoutException: Timeout expired after 5000milliseconds while awaiting InitProducerId Note: I have given the Kafka url invalid intentionally to fail the processor.
... View more
08-06-2023
11:48 PM
Hi kellerj. Yes it was due to the configuration error on the processor and I was able to see the bulletin corresponding to that on the bulletin board. The intention here is to route to failure relationship incase of any failure so that I can extract the bulletin message and send to the system so that I can track it outside of Nifi.
... View more
08-06-2023
11:40 PM
Thank you Matt for the reply. I also thought the same that may be some types of exceptions in the processor are handled in such a way that it cannot be routed to failure relationship.
... View more
08-02-2023
11:20 PM
Hi Matt. Thank you for the reply. Actually as per the first image I attached, what I did was initiating a single flow file into the flow through Handle Http request processor by hitting an API only once. The initiated flow file got stuck in queue before the PublishKakfa_2_6 processor. What I tried is to route the flow file initiated to failure relationship so as get track of the failure. But it's not routed. So my question is whether there is a way to route the flow file to failure relationship without the flow file being stuck in queue? Note: I intentionally gave the Publishkafka_2_6 processor's credentials wrong so that I can able to reproduce this scenario.
... View more
08-02-2023
02:20 AM
In Apache NiFi, the flow file got stuck permanently in queue when the downstream processor has some errors. I am looking to route the flow file to failure relationship so that I can handle the failure and extract the failure log. But in some cases the flow file got stuck in queue permanently which makes routing to failure relationship impossible. Is there a way to resolve the issue of flow file getting stuck? If not, is there a way to get notified that a particular flow file waits in which queue and which downstream processor in the processor group has error, so that I can track the failure? Downstream processor's settings and configuration: Note: Nifi is the part of the application we use to process files. We are looking for handling failure in Nifi processors without explicitly visiting NiFi UI every time (Getting to know about failures in NiFi processors from the system instead of visiting NiFi UI ). In the case mentioned above, it is impossible to route to failure relationship.
... View more
Labels:
- Labels:
-
Apache NiFi