# Docker 安装kafka
由于kafka需要zookeeper管理
`docker run -d --restart=always --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper`
# 开始安装
```shell
docker run -d --restart=always --name kafka -p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=10.160.6.161:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.160.6.161:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
```
# 测试安装结果
进入容器:`docker exec -it kafka bash`
切换到kafka可执行文件目录:`/opt/kafka_2.13-2.8.1/bin/`
## 创建一个名为 test 的 topic
`./kafka-topics.sh --create --zookeeper 10.160.6.161:2181 --replication-factor 1 --partitions 1 --topic test`
## 打开一个消费者监听消息
`./kafka-console-consumer.sh --bootstrap-server 10.160.6.161:9092 --topic test --from-beginning`
## 打开一个消息提供者
重新打开一个ssh窗口,进入容器,并切换到可执行文件目录
`./kafka-console-producer.sh --broker-list 10.160.6.161:9092 --topic test`

# 连接kafka测试Java代码
> [链接](https://gitee.com/levnli/springboot-kafka.git)
Docker 安装kafka