Docker中安装kafka

参考

官方：
kafka 下载地址
docker上启动kafka

一、Docker 安装 kafka

1、下载zookeeper镜像

docker pull wurstmeister/zookeeper

2、下载kafka镜像

docker pull wurstmeister/kafka

3、启动zookeeper

docker run -d --name zookeeper -p 2181:2181  -t wurstmeister/zookeeper

4、启动kafka

docker run -d --name kafka --publish 9092:9092 --link zookeeper:zookeeper -e KAFKA_BROKER_ID=1  -e HOST_IP=127.0.0.1  -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092  -e KAFKA_ADVERTISED_HOST_NAME=127.0.0.1 -e KAFKA_ADVERTISED_PORT=9082  --restart=always  -t  wurstmeister/kafka

5、进入容器

docker exec -it ${CONTAINER ID} /bin/bash

进入kafka的bin目录下

cd /opt/kafka_2.18/bin

6、创建topic

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

7、运行生产者

./kafka-console-producer.sh --broker-list localhost:9092 --topic topic-name

8、运行消费

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic topic-name

9、kafka 其他命令：

1） 查看已经创建的Topic

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