I'm currently working consumekafka poll messsage every interval 500 to 10000 records, while nifi iteration happen every 30 seconds once. i want to consumekafka once all jobs completed poll the next iteration. But consumekafka processor doesn't support upstream connection. can you help me out from this issue or could please suggest me how i can resolve?
once puthdfs success i need to consume next iteration here i mentioned nifi workflow.