搭建环境
安装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"）即可。
参考文档
关于作者
后端程序员，五年开发经验，从事互联网金融方向。技术公众号「清泉白石」。如果您在阅读文章时有什么疑问或者发现文章的错误，欢迎在公众号里给我留言。