Not able to operate kafka

Technical Discussions Apache Kafka
#1

Can you please help with the step by step process of starting the Kafka broker on cloudx lab ?
also adding the dependent jar files to run the producer and consumer

#2

Hi, @Pankaj_Bodhale

Here are the compiled steps on running Kafka.

Create your own topic, for instance I have used the topic name as “satyajitdas”

  1. export PATH=$PATH:/usr/hdp/current/kafka-broker/bin
  2. kafka-topics.sh --create --zookeeper cxln1.c.thelab-240901.internal:2181 --replication-factor 1 --partitions 1 --topic satyajitdas
  3. kafka-topics.sh --list --zookeeper cxln1.c.thelab-240901.internal:2181
  4. kafka-console-producer.sh --broker-list cxln4.c.thelab-240901.internal:6667 --topic satyajitdas

#kafka-console-producer.sh --broker-list cxln4.c.thelab-240901.internal:6667 --topic satyajitdas

  1. ls /brokers/ids -to get the ids of

cxln1.c.thelab-240901.internal

  1. kafka-console-consumer.sh --zookeeper cxln1.c.thelab-240901.internal:2181 --topic satyajitdas --from-beginning

All the best!