ZooKeeper - studiofu/brain GitHub Wiki

# create zookeeper and the required port is 2181
docker run -d --name zookeeper -p 2181:2181 jplock/zookeeper

# create kafka and the required ports are 7203 and 9092
docker run -d --name kafka -p 7203:7203 -p 9092:9092 -e KAFKA_ADVERTISED_HOST_NAME=<HOST_IP> -e ZOOKEEPER_IP=<HOST_IP> ches/kafka

# create the kafka topics senz
docker run --rm ches/kafka kafka-topics.sh --create --topic senz --replication-factor 1 --partitions 1 --zookeeper <HOST_IP>:2181

# list the kafka topics
docker run --rm ches/kafka kafka-topics.sh --list --zookeeper <HOST_IP>:2181

# produce messages for testing
docker run --rm --interactive ches/kafka kafka-console-producer.sh --topic senz --broker-list <HOST_IP>:9092

# consume messages
docker run --rm ches/kafka kafka-console-consumer.sh --topic senz --from-beginning --zookeeper <HOST_IP>:2181

# access zookeeper for testing
docker exec -it zookeeper bash

# access zookeeper cli
bin/zkCli.sh -server 127.0.0.1:2181

# access the key value in zookeeper cli
ls /

# create node
create /path /data

# create node with value
create /mytest1 value1

# set node value
set /mytest1 value2

# show stats
stat /mytest1

# check zookeeper status 
./zkServer.sh status