# 安装启动zookeeper

docker run -d --name zookeeper --publish 2181:2181 --volume /etc/localtime:/etc/localtime zookeeper:latest

--network 指定的网络
-p：设置映射端口（默认2181）
-d：后台启动

# 启动kafka

docker run -d --name kafka  -p 9092:9092 --link zookeeper -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.78.129:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092  wurstmeister/kafka

参数说明：
–link 用于容器直接的互通。
-e KAFKA_BROKER_ID=0 一个 kafka节点 就是一个 broker。一个集群由多个 broker 组成。一个 broker可以容纳多个 topic
-e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 配置zookeeper管理kafka的路径
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://139.226.179.239:9092 把kafka的地址端口注册给zookeeper，若远程访问要改成外网IP,千万注意是外网IP，很多文章只说是宿主机IP, 演示例子上写的是内网IP，很容易被误导
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口
-v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间

# 安装启动可视化管理界面

docker run -d --name kafka-map  -p 9001:8080  -v /opt/kafka-map/data:/usr/local/kafka-map/data  -e DEFAULT_USERNAME=admin  -e DEFAULT_PASSWORD=admin  dushixiang/kafka-map:latest

访问：
http://192.168.78.129:9001

添加192.168.78.129:9092

外部客户端访问使用这个192.168.78.129:9092

测试：

//新开docker终端
1创建主题

docker exec -it kafka /bin/bash
cd /opt/kafka/bin
./kafka-topics.sh --create --topic test-kafka --bootstrap-server localhost:9092

//新开docker终端
2消费者

docker exec -it kafka /bin/bash
cd /opt/kafka/bin
./kafka-console-consumer.sh --topic test-kafka --from-beginning --bootstrap-server localhost:9092

//新开docker终端
3生产者
 

docker exec -it kafka /bin/bash
cd /opt/kafka/bin
./kafka-console-producer.sh --topic test-kafka --bootstrap-server localhost:9092