docker部署kafka，外网可访问

Love The Way You Lie 2023-07-11 15:22 3阅读 0赞

# 1.拉取镜像 #

拉取zookeeper镜像

docker pull wurstmeister/zookeeper

拉取kafka镜像

docker pull wurstmeister/kafka

# 2. 启动容器 #

启动zookeeper

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

启动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://139.226.179.239:9092  -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka

# 3. 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** 容器时间同步虚拟机的时间

# 4.测试 #

## 创建topic ##

进入kafka容器

docker exec -it kafka /bin/bash

进入目录

cd opt/kafka_2.12-2.4.0/

创建测试topic

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

## 生产者发布 ##

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

![在这里插入图片描述][20200306153730890.png]

## 本地消费者订阅 ##

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092  --topic test-topic

![在这里插入图片描述][20200306153852974.png]

## java程序远程消费者客户端订阅 ##

![在这里插入图片描述][20200306153953931.png]

[20200306153730890.png]: https://img-blog.csdnimg.cn/20200306153730890.png
[20200306153852974.png]: https://img-blog.csdnimg.cn/20200306153852974.png
[20200306153953931.png]: https://img-blog.csdnimg.cn/20200306153953931.png