I am learning how to use the PutKafka processor to store my live trucking data as a message into kafka. However, when I start my dataflow, I receive the following error message:
I also included the property values that I have set for my PutKafka processor:
The Client Name value is Zookeeper.
I have the latest version of HDF 1.2.
Why am I receiving this error?
Here is my nifi template:
Any help is highly appreciated! Thank you!
Your port number for Kafka broker is wrong, the default on Sandbox is 6667. You are using 2181 which is the Zookeeper's port.
I added localhost:6667 to the property value section of the PutKafka processor. I am still getting the same error. Any other ideas on how to solve this error? Thank you again.
hi all, i'm still getting "PutKafka Error : failed while waiting for acks from kafka" error though i see some values under "In" & "Read".
but i see attached consumer console error.
Also,i see something strange here. When i remove out Kafka from "maintenance mode" on Ambari and start the kafka broker,
it gets stopped by itself after a while.
Note: I'm using HDP 2.6