一、docker-compose.yml
先创建目录 /data/docker/kafka/， 要挂载到kafka容器中
version: '3.2'
services:
zookeeper:
image: wurstmeister/zookeeper
container_name: zookeeper
ports:
- "2181:2181"
restart: always
kafka:
image: wurstmeister/kafka
container_name: kafka
ports:
- "9092:9092"
environment:
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
- KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.36.128:9092 #本机服务器IP
- KAFKA_LISTENERS=PLAINTEXT://:9092
volumes:
- /data/docker/kafka/:/var/run/
restart: always
docker-compose up -d
- -d 的意思是docker后台启动镜像
二、验证是否安装
先试用docker ps 查看是否启动
# 1.通过容器名称进入到kafka容器中：
docker exec -it kafka /bin/bash
# 2.创建一个名称为test的topic：
kafka-topics.sh --zookeeper zookeeper:2181 \
--describe --topic test
# 3.打开生产者发送若干条消息：
kafka-console-producer.sh --topic=test \
--broker-list kafka:9092
# 4.开发消费者接收消息：
kafka-console-consumer.sh \
--bootstrap-server kafka:9092 \
--from-beginning --topic test
