kafka docker搭建kafka集群

浅浅的花香味﹌ 2022-10-14 14:56 269阅读 0赞

# 1 环境概述 #

192.168.38.50 zookeeper
    192.168.38.51 kafka
    192.168.38.52 kafka
    192.168.38.53 kafka

# 2 docker 安装zookeper #

#下载镜像
    docker pull zookeeper
    
    #运行
    docker run --name zookeeper \
    -v /usr/local/zookeeper:/data \
    -p 2181:2181 \
    -d  zookeeper
    
    #查看
    docker ps

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70]

# 3 安装kafka集群 #

## 3.1 192.168.38.51 ##

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

## 3.2 192.168.38.52 ##

docker run  -d --name kafka -p 9092:9092 \
    -e KAFKA_BROKER_ID=1 \
    -e KAFKA_ZOOKEEPER_CONNECT=192.168.38.50:2181 \
    -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.38.52:9092  \
    -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092  \
    -v /etc/localtime:/etc/localtime \
    wurstmeister/kafka:2.12-2.2.2

## 3.3 192.168.38.53 ##

docker run  -d --name kafka -p 9092:9092 \
    -e KAFKA_BROKER_ID=2 \
    -e KAFKA_ZOOKEEPER_CONNECT=192.168.38.50:2181 \
    -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.38.53:9092  \
    -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092  \
    -v /etc/localtime:/etc/localtime \
    wurstmeister/kafka:2.12-2.2.2

## 4 查看zk ##

docker exec -it zookeeper /bin/bash
    cd bin/
    ./zkCli.sh
    ls /brokers/ids

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

## 5 安装 kafka-manager ##

docker run -d --name kafka-manager \
    -p 9000:9000 \
    --restart=always \
    --env ZK_HOSTS=192.168.38.50:2181 \
    sheepkiller/kafka-manager

## 6 测试 ##

#进入容器
    docker exec -it kafka /bin/bash
    #创建2副本3分区主题
    /opt/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.38.50:2181 --replication-factor 2 --partitions 3 --topic rosh-test
    #查看主题
    /opt/kafka/bin/kafka-topics.sh --describe  --zookeeper 192.168.38.50:2181  --topic rosh-test

![在这里插入图片描述][20210522111936457.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70]: /images/20221014/a36ed4c807c14bf59ae3c4dde034d168.png
[20210522111821172.png]: /images/20221014/1212a1e664b645e8bbc36b265560d9db.png
[20210522111936457.png]: /images/20221014/882cb5083f11421f8c9b61afe07963ca.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 1]: /images/20221014/63c5bbf3949a43a4a30d31a7b64c87f3.png