NiFi PublishKafka_0_10 processor

[#1]

Hi,

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

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)

[#2]

@dhieru singh

What does the config of the PublishKafka processor look like?

[#3]

kafkaconfig2.pngHi @Wynner Please find attached image

[#4]

@dhieru singh

What about the Scheduling and Properties tabs?

[#5]

Hi @Wynner

Thanks for your response. Here is the properties tab

[#6]

@Wynner

Here is the scheduling tab.

[#7]

@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?

[#8]

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

[#9]

@dhieru singh

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

[#10]

@Wynner

Thanks a lot for your patience.

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