上傳：scala-2.11.4.tgz到/usr/local目錄下
執(zhí)行命令：
tar -zxvf scala-2.11.4.tgz
rm -rf scala-2.11.4.tgz
mv scala-2.11.4/ scala
配置scala的環(huán)境變量：
vim ~/.bashrc
添加內(nèi)容：
export SCALA_HOME=/usr/local/scala
export PATH=$PATH:$SCALA_HOME/bin
執(zhí)行命令：source ~/.bashrc
執(zhí)行命令查看scala是否安裝成功：source ~/.bashrc
上傳kafka_2.9.2-0.8.1.tgz到/usr/local目錄下
執(zhí)行命令：
tar -zxvf kafka_2.9.2-0.8.1.tgz
rm -rf kafka_2.9.2-0.8.1.tgz
mv kafka_2.9.2-0.8.1/ kafka
vim /usr/local/kafka/config/server.properties
修改內(nèi)容：
broker.id：依次增長的整數(shù)：0 ?1 ?2，集群中Broker的唯一id
zookeeper.connect=192.168.2.161:2181,192.168.2.162:2181,192.168.2.163:2181
安裝saf4j
上傳slf4j-1.7.6.zip到/usr/local目錄下
執(zhí)行命令：
unzip slf4j-1.7.6.zip
cp /usr/local/slf4j-1.7.6/slf4j-nop-1.7.6.jar /usr/local/kafka/libs/
rm -rf slf4j-1.7.6
rm -rf slf4j-1.7.6.zip
執(zhí)行命令啟動kfka:
nohup /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &
cat nohup.out
執(zhí)行命令:jps查看kfka進程是否開啟
測試：
/usr/local/kafka/bin/kafka-topics.sh --zookeeper 192.168.2.161:2181,192.168.2.162:2181,192.168.2.163:2181 --topic test --replication-factor 1 --partitions 1 --create
/usr/local/kafka/bin/kafka-console-producer.sh --broker-list 192.168.2.161:9092,192.168.2.162:9092,192.168.2.163:9092 --topic test
/usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper 192.168.2.161:2181,192.168.2.162:2181,192.168.2.163:2181 --topic test --from-beginning
