Docker部署Kafka

一、拉取镜像

docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka

二、启动zookpeer

docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper

三、启动kafka

docker run -d --name kafka \
-p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=192.168.56.10:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.56.10:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka

注意修改自己ip地址

四、测试

1、进入kafka容器

docker exec -it kafka bash

2、进入kafak脚本目录

cd /opt/kafka_2.13-2.8.1/bin

注意修改自己kafka版本

3、创建主题

kafka-topics.sh --create --zookeeper 192.168.56.10:2181 --replication-factor 1 --partitions 1 --topic topic_1  

这里创建了一个topic_1主题。

4、添加消息

生产者发送消息

kafka-console-producer.sh --broker-list 192.168.56.10:9092 --topic topic_1

此时进入发送消息界面：

5、消费消息

消费者消费消息

kafka-console-consumer.sh --bootstrap-server 192.168.56.10:9092 --topic topic_1 --from-beginning

测试进入消费消息窗口：