// 通过wget下载zookeeper安装包

[bigdata@linux ~]$ wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

// 将zookeeper解压到安装目录

[bigdata@linux ~]$ tar –xf zookeeper-3.4.10.tar.gz –C ./cluster

// 进入zookeeper安装目录

[bigdata@linux cluster]$ cd zookeeper-3.4.10/

// 创建data数据目录

[bigdata@linux zookeeper-3.4.10]$ mkdir data/

// 复制zookeeper配置文件

[bigdata@linux zookeeper-3.4.10]$ cp ./conf/zoo_sample.cfg ./conf/zoo.cfg  

// 修改zookeeper配置文件

[bigdata@linux zookeeper-3.4.10]$ vim conf/zoo.cfg

dataDir=/home/bigdata/cluster/zookeeper-3.4.10/data  #将数据目录地址修改为创建的目录

// 启动Zookeeper服务

[bigdata@linux zookeeper-3.4.10]$ bin/zkServer.sh start

// 查看Zookeeper服务状态

[bigdata@linux zookeeper-3.4.10]$ bin/zkServer.sh status

ZooKeeper JMX enabled by default

Using config: /home/bigdata/cluster/zookeeper-3.4.10/bin/../conf/zoo.cfg

Mode: standalone

// 关闭Zookeeper服务

[bigdata@linux zookeeper-3.4.10]$ bin/zkServer.sh stop

// 通过wget下载zookeeper安装包

[bigdata@linux ~]$ wget http://www.apache.org/dyn/closer.lua/flume/1.8.0/apache-flume-1.8.0-bin.tar.gz

// 将zookeeper解压到安装目录

[bigdata@linux ~]$ tar –xf apache-flume-1.8.0-bin.tar.gz –C ./cluster

// 等待项目部署时使用

// 通过wget下载zookeeper安装包

[bigdata@linux ~]$ wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/0.10.2.1/kafka_2.11-0.10.2.1.tgz

// 将kafka解压到安装目录

[bigdata@linux ~]$ tar –xf kafka_2.12-0.10.2.1.tgz –C ./cluster

// 进入kafka安装目录

[bigdata@linux cluster]$ cd kafka_2.12-0.10.2.1/  

// 修改kafka配置文件

[bigdata@linux kafka_2.12-0.10.2.1]$ vim config/server.properties

host.name=linux                  #修改主机名

port=9092                         #修改服务端口号

zookeeper.connect=linux:2181     #修改Zookeeper服务器地址

// 启动kafka服务 !!! 启动之前需要启动Zookeeper服务

[bigdata@linux kafka_2.12-0.10.2.1]$ bin/kafka-server-start.sh -daemon ./config/server.properties

// 关闭kafka服务

[bigdata@linux kafka_2.12-0.10.2.1]$ bin/kafka-server-stop.sh

// 创建topic

[bigdata@linux kafka_2.12-0.10.2.1]$ bin/kafka-topics.sh –create –zookeeper linux:2181 –replication-factor 1 –partitions 1 –topic recommender

// kafka-console-producer

[bigdata@linux kafka_2.12-0.10.2.1]$ bin/kafka-console-producer.sh –broker-list linux:9092 –topic recommender

// kafka-console-consumer

[bigdata@linux kafka_2.12-0.10.2.1]$ bin/kafka-console-consumer.sh –bootstrap-server linux:9092 –topic recommender