Docker安装Kafka（内含zookeeper）

因为kafka是基于zookeeper做的，所以必须要有zookeeper

一、Zookeeper

1.拉取镜像

1. docker pull zookeeper:3.7.0

复制代码

2.运行

1. docker run --restart=always \
2.   --log-driver json-file \
3.   --log-opt max-size=100m \
4.   --log-opt max-file=2  \
5.   --name zookeeper -p 2181:2181 \
6.   -v /etc/localtime:/etc/localtime:ro \
7.   -d zookeeper:3.7.0

复制代码

3.检查是否运行成功

1. docker exec -it zookeeper /bin/sh
2. zkCli.sh -server 192.168.101.129:2181

复制代码

二、Kafka

1.拉取镜像

wurstmeister是一个官方的镜像仓库直接拉失败了，所以包了一层，要是还不可，去阿里弄个镜像加速器配上

1. docker pull wurstmeister/kafka

复制代码

就是这里
https://cr.console.aliyun.com/cn-hangzhou/instances/mirrors

2. 创建挂载目录好日志

2.1创建挂载目录

1. mkdir -p /home/kafka/{data,config}

复制代码

3.启动

注意：192.168.101.129这个地点必要替换成你本身的服务器IP

1. docker run --privileged=true \
2. --log-driver json-file \
3. --log-opt max-size=100m \
4. --log-opt max-file=2 \
5. --name kafka -p 9092:9092 \
6. -e KAFKA_BROKER_ID=0 \
7. -e KAFKA_ZOOKEEPER_CONNECT=192.168.101.129:2181/kafka \
8. -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.101.129:9092 \
9. -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
10. -e ALLOW_PLAINTEXT_LISTENER=yes \
11. -e KAFKA_HEAP_OPTS='-Xms512M -Xmx4G' \
12. -v /home/kafka/data:/wurstmeister/kafka/data \
13. -v /home/kafka/config:/wurstmeister/kafka/config \
14. -v /etc/localtime:/etc/localtime \
15. -d wurstmeister/kafka

复制代码

4.测一下

1.进去

1. docker exec -it kafka /bin/bash

复制代码

2.创建测试主题

• 进入kafka
  
• 创建主题
  例如创建一个名为test-kafka的主题
  

1. kafka-topics.sh --create --topic test-kafka --bootstrap-server 192.168.101.129:9092

复制代码

• 查看你刚才建立的主题
  

1. kafka-topics.sh --describe --topic test-kafka --bootstrap-server 192.168.101.129:9092

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。