1.docker创建zookeeper
拉取zookeeper镜像
docker pull wurstmeister/zookeeper
运行
docker run --name=zookeeper -d -e ZOOKEEPER_CLIENT_PORT=2181 -p 2181:2181 -p 2888:2888 -p 3888:3888 confluentinc/cp-zookeeper:latest
获取zookeeper容器镜像IP
docker inspect zookeeper
2.docker创建kafka
获取本地ip
ipconfig
拉取kafka镜像
docker pull wurstmeister/kafka
运行
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=172.17.0.6:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.xx.xxx.220:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
日志查看启动情况
docker logs kafka
成功
验证
进入到terminal
或者
docker exec -it kafka bash
进入到脚本文件夹
cd /opt/kafka_2.13-2.8.1/bin
创建topic
kafka-topics.sh --zookeeper 172.17.0.6:2181 --create --topic test --partitions 1 --replication-factor 1
发布消息
kafka-console-producer.sh --broker-list 10.xx.xxx.220:9092 --topic test
订阅消息
kafka-console-consumer.sh --bootstrap-server 10.xx.xxx.220:9092 --topic test --from-beginning
没有问题
针对搭建zookeeper和kafka时所用到的参数，大家可以自行去其他博客查看，这里就不过多赘述。
————————————————
版权声明：本文为CSDN博主「拉普朗日」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/weixin_53349482/article/details/127087094