docker安装部署kafka
·
1、下载镜像
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka
2、启动zookeeper容器
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
3、启动kafka容器
说明:
(1)运行命令中的ip地址(172.18.88.135)改为宿主机器的IP地址
KAFKA_ZOOKEEPER_CONNECT=172.18.88.135:2181
KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.18.88.135:9092
(2)下面的运行命令放在一行执行
(3)如果是阿里云服务器,外网ip没有配置白名单的话,就换内网ip
docker run -d --name kafka \
-p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=172.18.88.135:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.18.88.135:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
4、测试kafka 进入kafka容器的命令行
docker exec -it 镜像id /bin/bash
5、启动消息发送方进到bin目录下边
kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka;
6、新开窗口启动消息接收方
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mykafka --from-beginning
转发链接:
https://www.cnblogs.com/kunshou/p/12910658.html
坑1:启动kafka时报错:
(1)删除kafka容器:
rocker rm 容器号
(2)ip换成内网ip,重新启动kafka。
退出容器:
exit
魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。
更多推荐


所有评论(0)