Docker之kafka安装-yellowcong

Dear 丶 2022-05-21 01:45 213阅读 0赞

> 通过docker安装kafka，对于开发者可以快速的搭建测试开发环境，是一个非常好方案，不需要手动的去下载安装包，修改配置文件，注意：这种方法只适用于开发和测试，生产环境禁用，由于docker重启后，挂载数据卷目录启动的服务不一定好用，数据容易丢失掉了。

## 安装准备 ##

zookeeker: docker pull zookeeper:latest
    kafka: docker pull wurstmeister/kafka:latest

## 启动zookeeper ##

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

## 启动kafa ##

#查看主机ip
    #当前我主机的ip是192.168.112.12
    ifconfig
     
    
    #启动容器
    #这个地方，需要设定当前机器的ip
    docker run -d --name kafka --publish 9092:9092  --link zookeeper  --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181  --env KAFKA_ADVERTISED_HOST_NAME=192.168.112.12  --env KAFKA_ADVERTISED_PORT=9092  --volume /etc/localtime:/etc/localtime  wurstmeister/kafka
    
    
    #进入容器
    docker exec -it ${CONTAINER ID} /bin/bash
    #创建topic
    #cd /opt/kafka_2.11-1.1.0/
    cd /opt/kafka_**
    
    #创建一个topic
    #zookeeper:2181 zookeeper服务的地址
    bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test
    
    #查看topic的列表
    bin/kafka-topics.sh --list --zookeeper zookeeper:2181

启动容器，并进入这个容器中，需要注意的是容器的ip地址是当前机器的ip地址。  
![这里写图片描述][70]  
可以看到，队列里面有一个test的topic  
![这里写图片描述][70 1]

## 测试kafka ##

#向kafka发送测试消息
    #输入一些测试消息。
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    
    #消费消息
    # 运行一个消息消费者，同样指定 topic 为 test，可以接收到生产者发送的消息。
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
    
    
    #描述topic的信息
     ./bin/kafka-topics.sh --describe --zookeeper zookeeper:2181 --topic test
    
    #查看消息消费条数
    bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1

查看test这个topic的信息  
![这里写图片描述][70 2]

查看test这个topic消费的消息条数  
![这里写图片描述][70 3]

## 启动多个实例 ##

启动多个的情况

#我们需要更改 端口指向即可
    docker run -d --name zookeeper2 --publish 2182:2181 --volume /etc/localtime:/etc/localtime zookeeper:latest
    #对于kafka  link了 zookeeper2  容器 直接使用容器端口，而不是宿主机映射端口。
    docker run -d --name kafka2 --publish 9093:9092  --link zookeeper2  --env KAFKA_ZOOKEEPER_CONNECT=zookeeper2:2181  --env KAFKA_ADVERTISED_HOST_NAME=192.168.112.12  --env KAFKA_ADVERTISED_PORT=9093  --volume /etc/localtime:/etc/localtime  wurstmeister/kafka

## 参考文章 ##

https://blog.csdn.net/snowcity1231/article/details/54946857  
https://www.jianshu.com/p/263164fdcac7  
https://www.cnblogs.com/huxi2b/p/6061110.html

[70]: /images/20220521/d48d09527f8d4a78a4ed6010008503b1.png
[70 1]: /images/20220521/c9ebe13947084b01a5b4d91d49d270c2.png
[70 2]: /images/20220521/649e1f8ca73b4c229c5724a08b073444.png
[70 3]: /images/20220521/156968a79b064b25a253f5695be91d36.png