虚拟机安装zookeeper和kafka
连接虚拟机,检查虚拟机配置
虚拟机中:右键打开终端,输入ifconfig
获取虚拟机ip
在FinalShell中完成配置
连接好虚拟机后进行操作:
安装zookeeper
# cd /usr/local/ # mkdir zookeeper # cd zookeeper #ls #pwd
6.复制这个路径到这里
7.将文件夹直接拽入这里
8.解压zookeeper解压包
tar -zxvf apache-zookeeper-3.6.3-bin.tar.gz
9.解压完后进入
10.进入conf目录 将zoo_sample.cfg 改名位zoo.cfg
11.回退到bin目录 启动zookeeper
# ./zkServer.sh start
出现这个说明启动成功了
关闭服务
安装Kafka
# cd ../ # mkdir kafka # cd kafka # pwd
路径粘贴到这里 拖入压缩包
然后解压
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
先启动生成者
启动成功
再连接一个虚拟机 启动消费者
# 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)要对应
还没有评论,来说两句吧...