# 下载镜像
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka
# 安装zookeeper
docker run -d --restart=always --log-driver json-file --log-opt max-size=100m --log-opt max-file=2 --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper
# 安装kafka (需指定 IP:2181)
docker run -d --restart=always --log-driver json-file --log-opt max-size=100m --log-opt max-file=2 --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=172.31.255.254:2181/kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.31.255.254:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime wurstmeister/kafka
# 测试
docker exec -it kafka /bin/bash
cd opt/kafka_2.13-2.8.1/bin
# 创建列队 topic
./kafka-topics.sh --create --bootstrap-server 172.31.255.254:9092 --replication-factor 1 --partitions 1 --topic test
# 查看所有列队
./kafka-topics.sh --list --bootstrap-server 172.31.255.254:9092
# 查看队列信息
./kafka-topics.sh --describe --topic test --bootstrap-server 172.31.255.254:9092
# 查看列队消息数量
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 172.31.255.254:9092 --topic test --time -1
# 生产消息
./kafka-console-producer.sh --broker-list 172.31.255.254:9092 --topic test
# 消费消息
./kafka-console-consumer.sh --bootstrap-server 172.31.255.254:9092 --topic test --from-beginning
