kafka quick commands

 topic 

docker exec -it zookeeper-1 bash

/kafka/bin/kafka-topics.sh \

--create \

--zookeeper zookeeper-1:2181 \

--replication-factor 1 \

--partitions 1 \

--topic Orders

 ./kafka/bin/kafka-consumer-groups.sh --bootstrap-server kafka-1:19092 --all-groups --describe

consumer

docker exec -it zookeeper-1 bash

/kafka/bin/kafka-console-consumer.sh \

--bootstrap-server kafka-1:9092 \

--topic Orders --from-beginning

/kafka/bin/kafka-console-consumer.sh \

--bootstrap-server kafka-1:9092 \

--topic Orders --from-beginning

/kafka/bin/kafka-console-consumer.sh \

--bootstrap-server kafka-1:9092 \

--topic Orders --from-beginning

/kafka/bin/kafka-console-consumer.sh \

--bootstrap-server kafka-1:29092 \

--topic Orders --from-beginning

/kafka/bin/kafka-console-consumer.sh \

--bootstrap-server 172.31.1.182:9092 \

--topic Orders --from-beginning

producer

docker exec -it zookeeper-1 bash

echo "New Order: 1" | \

/kafka/bin/kafka-console-producer.sh \

--broker-list kafka-1:9092 \

--topic Orders > /dev/null

echo "{"test":1}" | \

/kafka/bin/kafka-console-producer.sh \

--broker-list kafka-1:9092 \

--topic Orders > /dev/null

echo "{"test":1}" | \

/kafka/bin/kafka-console-producer.sh \

--broker-list kafka-1:19092 \

--topic Orders > /dev/null

show consumeers

./bin/kafka-consumer-groups.sh --bootstrap-server kafka-1:9092 --all-groups --describe