安裝JDK

第一步：上傳JDK 的linux安裝包

第二步：解壓到安裝目錄

tar -xvzf jdk-8u11-linux-x64.tar.gz -C /usr/local

第三步：配置環境變數

vim /etc/profile

#配置如下內容
#set java environment
	JAVA_HOME=/usr/local/jdk1.8.0_11
	CLASSPATH=.:$JAVA_HOME/lib.tools.jar
	PATH=$JAVA_HOME/bin:$PATH
	export JAVA_HOME CLASSPATH PATH

#編輯完退出，重新整理配置檔案
source /etc/profile
 

驗證安裝完成：

java -version

安裝配置Zookepper

第一步：下載並上傳zookeper的linux安裝包（下載地址：http://archive.apache.org/dist/zookeeper/）

第二步：解壓安裝包到安裝目錄

tar -xvzf zookeeper-3.4.6.tar.gz

第四步：進入zookeeper-3.4.6目錄，建立data目錄

mkdir data

第五步：進入conf目錄 ，把zoo_sample.cfg 改名為zoo.cfg

cd conf
mv zoo_sample.cfg zoo.cfg

第六步：開啟zoo.cfg檔案, 修改data屬性：dataDir=/root/zookeeper-3.4.6/data

啟動、停止Zookeeper

進入Zookeeper的bin目錄，啟動服務命令

./zkServer.sh start

停止服務命令

./zkServer.sh stop

檢視服務狀態：

./zkServer.sh status

安裝Kafka

第一步：下載並上傳zookeper的linux安裝包（下載地址：http://kafka.apache.org/downloads）

第二步：解壓安裝包到安裝目錄

tar -xvzf kafka_2.11-2.4.0.tgz -C /usr/local

第四步：進入kafka_2.11-2.4.0.tgz安裝目錄下的config目錄

cd /usr/local/kafka_2.11-2.4.0/config
 

第五步：編輯server.properties

vim server/properties

#修改如下配置
listeners=PLAINTEXT://127.0.0.1:9092

advertised.listeners=PLAINTEXT://127.0.0.1:9092

啟動、停止Kafka

1、啟動Kafka(注意啟動前要先啟動zookeper)
bin/kafka-server-start.sh config/server.properties &

2、停止Kafka
bin/kafka-server-stop.sh

3、建立Topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic jiangzh-topic

4、檢視已經建立的Topic資訊
bin/kafka-topics.sh --list --zookeeper localhost:2181

5、傳送訊息
bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic alex-topic

6、接收訊息
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic alex-topic --from-beginning