# 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)