kafka源碼導入idea

必備工具

• Win10
• Jdk1.8
• Zookeeper-3.4.10
• Scala- 2.12.5
• Gradle 3.3

• kafka-0.10.1.0-src

  準備以上環境請自行百度^-^，接下來就開始讓我們用idea編譯（ps：我用Gradle命令編譯源碼，然後再導入idea沒有成功）。

  idea配置環境

• idea配置Scala環境：如圖
  
  由於我是裝了scala的我就不卸載了。
• idea配置Gradle環境。如圖
  

配置kafka參數

點擊edit configuritions進行參數編寫啓動參數

配置好以後那麼啓動zookeeper，然後啓動kafka。
ps：網上都寫的 Use classpath of moudule：core，但是實際情況配置成core會報錯。配置成core_main完美解決。

最後檢驗kafka是否啓動成功

直接貼官方文檔 只要把.sh改成.bat就可以了。
下面爲測試kafka是否通過的腳本：

1. kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
2. kafka-topics.bat –list –zookeeper localhost:2181
3. kafka-console-producer.bat –broker-list localhost:9092 –topic test
4. kafka-console-consumer.bat –bootstrap-server localhost:9092 –topic test –from-beginning 然後我們就可以在producer的窗口輸入信息，然後觀察consumer的窗口是否有接受到消息。如果接受到消息，那麼恭喜調試源碼程序完美運行了。