前期準備：

• step1：安裝JDK1.8
• step2：安裝zookeeper3.4.9https://blog.csdn.net/qq_29425617/article/details/85266606
• step3： 安裝Gradle-4.10.3https://blog.csdn.net/qq_29425617/article/details/85266509
• step4：安裝scala-2.10.7https://blog.csdn.net/qq_29425617/article/details/85264283

一.kafka原始碼構建

完成上述準備工作後，我們在http://kafka.apache.org/

二.配置kafka

在kafka服務端使用log4j輸出日誌，啟動前需要把config目錄下的log4j.properties配置檔案放置到src/mai/scala路徑下，然後執行程式，才能正確輸出日誌資訊。

config目錄下的server.porperties是kafka的主要配置檔案，我們需要修改log.dirs用於儲存log檔案

log.dirs=D:\\kafka-0.10.0.1-src\\kafka-logs

配置kafka的啟動引數

• 配置kafka伺服器
• 
• 配置生產者
• 
• 配置消費者
• 

第一次啟動kafka時，idea會編譯整個專案，得到如下日誌資訊

三.驗證

1. 開啟zookeeper和並啟動kafka伺服器
2. 啟動生產者producer
3. 啟動消費者consumer
4. 在producer中輸入你好，我們就可以在看到 這條訊息出現在consumer，則表明搭建成功