搭建環境
安裝scala
安裝gradle
在kafka源碼的根目錄執行命令
gradle wrapper
gradle idea
打開IDEA，File -> Open -> kafka源碼項目，
配置config/server.properties，將zk的地址改為可用的地址，並啟動zk。
zookeeper.connect=localhost:2181
將log4j.properties放置到src/main/Scala
修改log4j.properties，增加kafka日志路徑
kafka.logs.dir=logs/my-kafka-log
配置啟動/調試參數
Main Class = kafka.Kafka
VM options = -Dcom.sun.management.jmxremote.port=9999 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false
Program arguments = config/server.properties
測試運行結果
啟動Kafka Server，使用客戶端生產、消費消息
可以正常生產、消費。
測試調試結果
異常解決
Failed to notify build listener.
說明版本不對，更換成build.gradle中的版本（gradleVersion = "3.2.1"）即可。