一希太、Zookeeper環(huán)境配置
????（1）.下載zookeeper安裝包http://apache.fayea.com/zookeeper/current/沙热；
????（2）加壓壓縮文件到指定位置湖员，本文加壓到E:\Kafka\zookeeper-3.4.12，并新建一個(gè)文件夾data哈街；
????（3）進(jìn)入到conf目錄幔摸，復(fù)制zoo_sample.cfg為zoo.cfg，修改其中dataDir為新建文件夾data對(duì)的路徑沥寥；
????（4）進(jìn)入bin目錄碍舍，雙擊zkServer.cmd即可啟動(dòng)zookeeper。
二营曼、Kafka環(huán)境配置
????（1）下載Kafka二進(jìn)制包乒验，http://kafka.apache.org/downloads.html；
????（2）解壓安裝包到指定目錄下蒂阱，這里我們解壓到E:\Kafka\kafka_2.11-2.1.0锻全，并新建一個(gè)命名為logs的空文件夾；
????（3）進(jìn)入config目錄录煤，編輯server.properties 文件鳄厌，修改 log.dirs 屬性部分地址為新建logs文件夾的路徑；
????（4）在E:\Kafka\kafka_2.11-2.1.0\目錄下打開(kāi)命令窗口妈踊，輸入如下命令設(shè)置CLASSPATH了嚎；
SET CLASSPATH=.;
????（5）然后輸入下面的命令啟動(dòng)kafka-server；
.\bin\windows\kafka-server-start.bat .\config\server.properties
執(zhí)行結(jié)果
????（6）測(cè)試
- 創(chuàng)建topic：在E:\Kafka\kafka_2.11-2.1.0\bin\windows下打開(kāi)命令窗口廊营，輸入下面的命令創(chuàng)建test主題
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test.topic
- 打開(kāi)消息生產(chǎn)者：在上一步的命令窗口接著輸入
kafka-console-producer.bat --broker-list localhost:9092 --topic test.topic
- 創(chuàng)建一個(gè)消息消費(fèi)者：在E:\Kafka\kafka_2.11-2.1.0\bin\windows下打開(kāi)命令窗口歪泳，輸入下面的命令：
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
-
在producer輸入內(nèi)容就會(huì)在consumer看到對(duì)應(yīng)顯示
