记录一次配置过程
安装docker
参加下面链接的第一部分
Ubuntu20.04使用docker安装kafka服务-CSDN博客
安装zookeeper
docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper
安装kafka服务
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=[你的IP地址]:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://[你的IP地址]:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
改成我自己的本机的就是:
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.147.131:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.147.131:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
进入docker
执行docker ps -a命令,查看结果如下:
注意上述结果显示kafka和zookeeper都是已关闭状态,需要开启,使用下面的命令:docker start 容器id,即
docker start a01c
docker start c0c7
注意要先启动父容器(或者说是依赖项zookeeper),再启动子容器kafka,容器id输入前几位有区分即可,不必全部输入,也不必补全(tab不会给你补全)
执行docker ps -a命令,再次查看结果如下:
ok这就启动成功了
然后执行命令进入docker
docker exec -it [container-id] /bin/sh #container-id就是上图中c0c7这一串数字,执行命令时只需要输入前几个数字/字母即可
cd /opt/kafka/bin #跳转到kafka目录下的bin目录,这下面有一些可执行脚本
换成我的本机就是执行下面的命令:
docker exec -it c0c7 /bin/sh #container-id就是上图中41b8e4db352f这一串数字,执行命令时只需要输入前几个数字/字母即可
cd /opt/kafka/bin #跳转到kafka目录下的bin目录,这下面有一些可执行脚本
得到下面的结果:
生产者消费者模式初体验
启动生产者
注意下面的ip:192.168.147.131要和你本机ip一致,使用ifconfig命令查看
./kafka-console-producer.sh --broker-list 192.168.147.131:9092 --topic wxj
打开另一个终端,启动消费者
注意ip要一致,topic要一致
docker exec -it c0c7 /bin/sh
cd /opt/kafka/bin
./kafka-console-consumer.sh --bootstrap-server 192.168.147.131:9092 --topic wxj
运行效果如下:
其他一点别的,就是常识啦,比如如何退出生产者消费者的环境,ctrl+c,ctrl+d都试试,如何退出容器,可以试试输入exit命令
ok 完事了,还是去探索腾讯云的kafka服务吧