docker安装kafka和zookeeper，kafka学习一

小灰灰 2021-05-09 20:35 638阅读 0赞

## 说明 ##

kafka需要zookeeper来管理，所以要先安装zookeeper

## 1.安装zookeeper ##

拉取zookeeper镜像

docker pull wurstmeister/zookeeper

运行zookeeper容器

docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper

## 2.安装kafka ##

拉取kafka镜像

docker pull wurstmeister/kafka

运行kafka容器

docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 
    -e KAFKA_ZOOKEEPER_CONNECT=106.55.55.249:2181/kafka 
    -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://106.55.55.249:9092 
    -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
    -v /etc/localtime:/etc/localtime wurstmeister/kafka

参数解析：

-e KAFKA_BROKER_ID=0  在kafka集群中，每个kafka都有一个BROKER_ID来区分自己
    
    -e KAFKA_ZOOKEEPER_CONNECT=106.55.55.249:2181/kafka 配置zookeeper管理kafka的路径106.55.55.249:2181/kafka
    
    -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://106.55.55.249:9092 把kafka的地址端口注册给zookeeper。
    
    -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口
    
    -v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间

## 3.测试kafka是否搭建成功 ##

shell连接工具开设两个页面，一个生产数据，一个消费数据

1.进入kafka容器内

docker exec -it 容器id /bin/bash

2.进入/opt/kafka\_2.12-2.5.0/bin目录

cd /opt/kafka_2.12-2.5.0/bin

3.运行kafka生产者发送消息

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

4.运行kafka消费者消费消息

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sun --from-beginning

5.测试结果，在生产者一端发送消息，在消费者一端查看是否能接受到消息  
发送数据  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70]  
接受数据  
![在这里插入图片描述][20200617174553698.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTAyNTM2Mg_size_16_color_FFFFFF_t_70]: /images/20210505/858a890d2ff24f098e19931cb534c02e.png
[20200617174553698.png]: /images/20210505/1d1336748cf3462ab90be7e489f196fc.png