【kafka-部署】docker快速构建kafka测试环境（单机）

古城微笑少年丶 2023-02-10 05:22 12阅读 0赞

### 1、下载kafka和zookeeper镜像 ###

docker pull wurstmeister/zookeeper
    docker pull wurstmeister/kafka

### 2、启动容器 ###

这里zk对应宿主机的端口不设置，默认随机分配。若想查看zookeeper映射的宿主机端口可用docker ps -a查看。

docker run -d --name zookeeper -p 2181 --volume /etc/localtime:/etc/localtime -t wurstmeister/zookeeper
    docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=[宿主机IP] --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime wurstmeister/kafka

进入容器操作

docker exec -it [容器ID] /bin/bash

### 3、修改配置 ###

kafka默认安装路径 /opt/kafka\_2.11-2.0.1

> 注意：  
> WARN \[Producer clientId=console-producer\] Error while fetching metadata with correlation id 1 : \{test=LEADER\_NOT\_AVAILABLE\} (org.apache.kafka.clients.NetworkClient)  
> 需要修改config/server.properties如下两项设置，然后重启docker才生效。

listeners=PLAINTEXT://localhost:9092
    advertised.listeners=PLAINTEXT://localhost:9092

### 4、测试 ###

#创建topic
    bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test
    #查看
    bin/kafka-topics.sh --list --zookeeper zookeeper:2181
    #生产者
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    #消费者
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

![format_png][]

image.png

至此简单的测试环境构建完成。

附录

$ docker ps // 查看所有正在运行容器
    $ docker stop containerId // containerId 是容器的ID
    
    $ docker ps -a // 查看所有容器
    $ docker ps -a -q // 查看所有容器ID
    
    $ docker stop $(docker ps -a -q) //  stop停止所有容器
    $ docker rm $(docker ps -a -q) //   remove删除所有容器

作者：粮忆雨  
链接：https://www.jianshu.com/p/4cc49ba6c26c  
来源：简书  
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy8xNDc4ODg1MS1kMDMyZWIyZGVkOGY0MDdmLnBuZz9pbWFnZU1vZ3IyL2F1dG8tb3JpZW50L3N0cmlwfGltYWdlVmlldzIvMi93LzgwMi9mb3JtYXQvd2VicA?x-oss-process=image/format,png