Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

NiFi PublishKafka_0_10 processor

avatar
Expert Contributor

Hi,

I am trying to publish to a kafka topic on a kafka broker. I am receving the error such as

27513-kafka2.png

relationship not specified; rolling back session: {}
org.apache.nifi.processor.exception.FlowFileHandlingException: StandardFlowFileRecord[uuid=be3d1509-fdc4-4235-a760-c8740a05883b,claim=,offset=0,,size=0] transfer relationship not specified
       at org.apache.nifi.controller.repository.StandardProcessSession.checkpoint(StandardProcessSession.java:248)
       at org.apache.nifi.controller.repository.StandardProcessSession.commit(StandardProcessSession.java:318)
       at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:28)
       at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1118)
       at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147)
       at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
       at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
       at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
       at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
       at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
       at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
       at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
       at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
       at java.lang.Thread.run(Thread.java:745)
1 ACCEPTED SOLUTION

avatar

@dhieru singh

Will you post the configuration of the GenerateFlowFile processor?

Are you seeing the same error now?

View solution in original post

20 REPLIES 20

avatar
Explorer

I had the same problem with PublishKafka_0_10 processor and I found that there is an open issue in JIRA

https://issues.apache.org/jira/browse/NIFI-3957

Meanwhile I solved the problem controlling the size of the FlowFile before with RouteOnAttribute

38399-routeonattribute-before-publishkafka.png

38400-routeonattribute-filesize-gt-0.png