虚拟机安装zookeeper和kafka

冷不防 2024-03-31 18:03 136阅读 0赞

连接虚拟机,检查虚拟机配置

虚拟机中:右键打开终端,输入ifconfig

获取虚拟机ip

1db8fc5ec6ba470a98f8746490fafbf7.png

在FinalShell中完成配置

2f8bdd042c6f4ac1a872eaffff4d8269.png

连接好虚拟机后进行操作:

安装zookeeper

# cd /usr/local/ # mkdir zookeeper # cd zookeeper #ls #pwd

24a1bfa280484ae7b18500c40e0fba9d.png

6.复制这个路径到这里

217b1663c94a45b4882d469532628ac5.png

7.将文件夹直接拽入这里

131c5067fac84935a5f383fdde8334fe.png

8.解压zookeeper解压包

tar -zxvf apache-zookeeper-3.6.3-bin.tar.gz

9.解压完后进入

2138879cdd8e4d118f2f566647e0c854.png

10.进入conf目录 将zoo_sample.cfg 改名位zoo.cfg

02e4e2cb474f408d8fbcd53bea214f52.png

11.回退到bin目录 启动zookeeper

# ./zkServer.sh start

出现这个说明启动成功了

b16a0567cd764f11baf8c06b8f3a07bd.png

关闭服务

a1b41b3f61cb4458840df56ad91ad43f.png

安装Kafka

# cd ../ # mkdir kafka # cd kafka # pwd

路径粘贴到这里 拖入压缩包

ba10b5aacafa4237bd285009c4d1c975.png

然后解压

tar -zxvf kafaka_2.11-2.4.0.tgz

然后进入

# cd kafka_2.11-2.4.0/ # cd bin/ # ls # ./kafka-server-start.sh -daemon ../config/server.properties 启动之后模拟生产者和消费者 消费者指令—- ./kafka-console-consumer.sh —bootstrap-server 127.0.0.1:9092 —topic zhencongtest —from-beginning 生产者指令—— ./kafka-console-producer.sh —broker-list 127.0.0.1:9092 —topic zhencongtest

先启动生成者

启动成功

c9b7b0d74c52430ba438525813a42bb4.png

再连接一个虚拟机 启动消费者

# cd /usr/local/kafka/kafka_2.11-2.4.0/bin/ ./kafka-console-consumer.sh —bootstrap-server 127.0.0.1:9092 —topic zhencongtest —from-beginning 启动消费者

生产者发送消息 消费者会接受 但是消费者和生成者的标识( —topic zhencongtest)要对应

d7a649907953440d952d37e6043eafcf.png

d7baabd770144224b78011ab77c19de2.png

发表评论

表情:
评论列表 (有 0 条评论,136人围观)

还没有评论,来说两句吧...

相关阅读