環境搭建：
一 下載源碼。
1.源碼下載：
從GitHub下載https://github.com/apache/kafka.git。
下載完之后在IDEA setting--Plugins 處安裝Scala 插件，再按照提示下載scala jar包。
2.配置工程：
二 運行源碼
1.啟動kafka
Kafka.scala是kafka的啟動類，按照如下配置，指定配置文件路徑，就可以啟動起來了。
Program arguments 指定配置文件路徑：config/server.properties
vm o'ptions 指定log4j配置路徑：-Dlog4j.configuration=file:D:/myProject/kafka/config/log4j.properties
2.搭建zookeeper
從github下載zookeeper（https://github.com/apache/zookeeper.git），然后配置運行。
zookeeper的啟動類是QuorumPeerMain；配置如下：
