链接：https://pan.baidu.com/s/1IB_8fbWUq73o0_SrryCyCg 

提取码：gffl

使用vm虚拟三个linux主机 192.168.212.174 192.168.212.175 192.168.212.176 tar zxvf jdk-8u161-linux-x64.tar.gz vim /etc/profile #set java environment JAVA_HOME=/usr/local/jdk1.8 JRE_HOME=/usr/local/jdk1.8/jre CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin export JAVA_HOME JRE_HOME CLASS_PATH PATH source /etc/profile

2. 安装zookeeper

上传或者下载zookeeper安装包

解压安装包

修改配置文件

启动zookeeper

复制其他服务器 修改zoo.cfg 中的serverip 和data 中的myid 即可

启动全部zookeeper

3. 安装kafka

上传或者下载kafka安装包

解压安装包

修改配置文件

java -version wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper- 3.4.10/zookeeper-3.4.10.tar.gz tar -zxvf zookeeper-3.4.10.tar.gz mv zoo_sample.cfg ./zoo.cfg mkdir data vi zoo.cfg dataDir=/usr/local/zookeeper/data server.0=192.168.216.143:2888:3888 server.1=192.168.216.144:2888:3888 server.2=192.168.216.145:2888:3888 cd data vi myid 0./zkServer.sh start ./zkServer.sh status ./zkServer.sh stop wget http://mirror.bit.edu.cn/apache/kafka/1.0.0/kafka_2.11-1.0.0.tgz tar -zxvf kafka_2.11-1.0.0.tgz vi./kafka/config/server.propertiesbroker.id=0listeners=PLAINTEXT://192.168.216.13 0:9092zookeeper.connect=192.168.216.130:2181,192.168.216.131:2181,192.168.216.1 32:2181

启动全部kafka

./kafka-server-start.sh -daemon ../config/server.properties

在其中一台中创建topic

./kafka-topics.sh -create -zookeeper 192.168.216.148:2181 -replication-factor 3 -partitions 1 -topic my-replicated-topic

查看topic信息

./kafka-topics.sh -describe -zookeeper 192.168.216.148:2181 -topic my- replicated-topic

查看zook