Kafka(五) —— 服务端源码本地调试

搭建环境

安装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,使用客户端生产、消费消息

可以正常生产、消费。

测试调试结果

待解决问题

控制台不打印日志

参考文档

Kafka日志配置
Idea下Kafka源码阅读编译环境搭建

猜你喜欢

转载自www.cnblogs.com/fonxian/p/12105142.html