If we try the kafka commands in our cluster directly we will get error as shown in below image:
In order to use Kafka using in our cluster follow below steps
First update the below command in .bash_profile
export KAFKA_HOME=/usr/hdp/220.127.116.11-292/kafka export PATH=$PATH:$KAFKA_HOME/bin
source .bash_profile command to load the changes.
And if you want details like Zookeeper, bootstrap-server Hostname’s & their respective port no. we can get these kind of details in Ambari