Support Questions

Find answers, ask questions, and share your expertise

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

@dhieru singh

What does the config of the PublishKafka processor look like?

avatar
Expert Contributor

kafkaconfig2.pngHi @Wynner Please find attached image

31405-kafkaconfig1.png

avatar

@dhieru singh

What about the Scheduling and Properties tabs?

avatar
Expert Contributor

Hi @Wynner

Thanks for your response. Here is the properties tab

33383-31406-kafkaconfig2.png

avatar
Expert Contributor

@Wynner

Here is the scheduling tab.

33384-kafka3.png

avatar
@dhieru singh

So, there is a Kafka Broker running on the same system as NiFi?

Is this an HDF cluster?

Is 9092 the correct port?

avatar
Expert Contributor

Thanks for the response @Wynner

Yes this is a kafka broker running on the same system.

No it is not a HDF cluster

yes 9092 is the correct port

Thanks

avatar
@dhieru singh

Try putting the actual host name instead of localhost for the Kafka Broker property.

avatar
Expert Contributor

@Wynner

Thanks a lot for your patience.

I did try putting in the hostname instead of IP address but no success