搭建环境
安装scala
安装gradle
在kafka源码的根目录执行命令
gradle wrapper
gradle idea
打开IDEA,File -> Open -> kafka源码项目,
将log4j.properties放置到src/main/Scala
配置启动/调试参数
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,使用客户端生产、消费消息
可以正常生产、消费。
测试调试结果
待解决问题
控制台不打印日志