/opt/kafka/bin/kafka-topics.sh --zookeeper zookeeper:2181 --create --topic helloKafka --partitions 1 --replication-factor 1
Created topic "helloKafka".
echo "Hello, World" | /opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic helloKafka > /dev/null.
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic helloKafka --from-beginning
/opt/kafka/bin/kafka-topics.sh --describe --topic helloKafka --zookeeper zookeeper
Topic:helloKafka PartitionCount:1 ReplicationFactor:1 Configs: Topic: helloKafka Partition: 0 Leader: 1 Replicas: 1 Isr: 1
Zookeeper
docker exec -it [zk_container_id] ./bin/zkCli.sh ls /brokers/topics
docker-compose scale kafka=3
docker exec -it docker ps -aqf "name=microservicesusingkafka_consumer"
python consumer.py -t demo
docker exec -it docker ps -aqf "name=microservicesusingkafka_producer"
python prod.py -p 9092 -t demo -m something
docker exec -it docker ps -aqf "name=microservicesusingkafka_zookeeper
./bin/zkCli.sh ls /brokers/topics