Support Questions
Find answers, ask questions, and share your expertise
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

NiFi consumekafka upstream conection

NiFi consumekafka upstream conection




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.


consumekafka -> mergecontent->convertRecord->updateattribute->puthdfs



Don't have an account?
Coming from Hortonworks? Activate your account here