kafka command - amresh087/newronaRepos GitHub Wiki

//======================kafka setup

docker-compose up -d

docker-compose down

docker ps

#docker exec -it container name/id /bin/sh

docker exec -it kafka /bin/sh

Now inside of kafka you can use any lunex command

cd /opt/

ls

cd kafka

cd bin

cd ..

//=================create topic

./bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic mytopic1

// show all topic

./bin/kafka-topics.sh --list --zookeeper zookeeper:2181

./bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test

./bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic demo

//======console producer

./bin/kafka-console-producer.sh --topic demo --bootstrap-server localhost:9092

//=======consumer

./bin/kafka-console-consumer.sh --topic demo --bootstrap-server localhost:9092 --from-beginning