docker安装kafka
1、下载镜像
#下载zookeeper镜像
docker pull wurstmeister/zookeeper
# 下载kafka镜像
docker pull wurstmeister/kafka
2、先启动zookeeper
# 单机方式
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
3、启动kafka
# 单机方式 注：10.0.0.101:2181是zookeeper的地址
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=10.0.0.101:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.0.0.101:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
# 在我的服务器上实际启动kafka命令，注：139.9.88.113为当前主机地址，172.17.0.1:2181为zookeeper的地址
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=172.17.0.1:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://139.9.88.113:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
# 本地windows11中启动kafka
docker run -d --name kafka3 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=172.17.0.1:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
4、创建一个topic
#进入容器(${CONTAINER ID}替换成kafka容器ID)
docker exec -it ${CONTAINER ID} /bin/bash
cd opt/bin
#单机方式：创建一个主题
bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic mykafka
#运行一个生产者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
#运行一个消费者
bin/kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic mykafka --from-beginning
5、演示案例
- 生产者窗口案例
- 消费者窗口案例
原文地址：https://blog.csdn.net/PineSummer/article/details/140143996
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！