Kafka与Zookeeper在linux上的下载记录

1.先安装Zookeeper。

（1）打开虚拟机，使用FileZilla软件将安装包apache-zookeeper-3.5.7-bin.tar.gz上传到/opt/software目录。（直接拖拽或者右键需要上传的软件点击“上传”）。

（2）安装JDK并配置环境变量，此处略。（已安装过）

（3）解压缩ZooKeeper安装包至/opt/module目录下(使用putty软件或者直接在虚拟机中操作)

[root@sias ~]# cd /opt/software/

root@sias module]# tar -zxvf apache-zookeeper-3.5.7-bin.tar.gz -C /opt/module/

（3）将/opt/module/zookeeper-3.5.7/conf这个路径下的zoo_sample.cfg复制后，命名为zoo.cfg；

[root@sias conf]# cd /opt/module/apache-zookeeper-3.5.7-bin/conf/

[root@sias conf]# cp zoo_sample.cfg  zoo.cfg

(4) 修改路径为zkdir

[root@sias conf]# vi zoo.cfg

修改如下：

dataDir=/opt/module/apache-zookeeper-3.5.7-bin/zkdir

（5) 进入bin目录，启动ZooKeeper服务

[root@sias bin]# cd /opt/module/apache-zookeeper-3.5.7-bin/bin

[root@sias bin]# ./zkServer.sh start

(6)使用jps命令检查是否存在以下一个节点QuorumPeerMain,这表明Zookeeper安装成功。

2.安装kafka。

[root@sias software]# tar -xzf kafka_2.12-3.0.0.tgz -C /opt/module/

[root@sias software]# cd /opt/module/kafka_2.12-3.0.0/

[root@sias kafka_2.12-3.0.0]# vi config/server.properties

broker.id=0

listeners=PLAINTEXT://192.168.100.20:9092

log.dirs=/tmp/kafka-logs

zookeeper.connect=localhost:2181

[root@sias bin]# cd /opt/module/kafka_2.12-3.0.0/bin/

[root@sias bin]# ./kafka-server-stop.sh（若虚拟机原本就没有kafka，则不需要这个命令，否则会出现以下报错)

[root@sias bin]# ./kafka-server-start.sh -daemon ../config/server.properties

测试 Kafka，为了验证 Kafka 是否正常工作，可以创建一个主题并发送和接收消息。

创建主题——test

打开一个新的终端窗口，使用以下命令创建一个名为 ​​test​​ 的主题：

[root@sias kafka_2.12-3.0.0]# ./bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

开启一个新窗口，执行下面命令，开启生产者：

[root@sias kafka_2.12-3.0.0]# .bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092

在生产者控制台中输入一些消息，按回车键发送。

接收消息则打开一个新的终端窗口。

启动完可以切换到logs目录下查看日志，再打开两个shell页面，分别为生产和消费使用。

启动生产者服务，bin目录下。

[root@sias ~]# cd /opt/module/kafka_2.12-3.0.0/bin/

[root@sias bin]# ./kafka-console-producer.sh --topic test --bootstrap-server 192.168.100.20:9092

启动消费者服务：

[root@sias bin]# ./kafka-console-consumer.sh --topic test --bootstrap-server 192.168.100.20:9092

这是验证效果，此时可证明kafka安装成功。