前言

最近需要调试kafka源码,所以在本地idea配置一下运行环境,分享一下,给后面的新同学一个参考。

环境

下面是我用的环境,可以保证正确运行

  • 系统:mac os
  • jdk: 1.8.0_271
  • idea: 2020.2
  • kafka: 写这篇博文的时候,用的是最新的trunk分支的代码

安装scala插件

先安装scala插件,安装完成重启idea,我这已经安装过了

克隆代码

克隆kafka的代码到本地,如果克隆不成功可以直接下载到本地,怎么弄下来的不重要,重要的是代码下载到本地:

git clone https://github.com/apache/kafka.git

idea配置

1. 用idea打开前面下载的kafka项目代码

2. 引入log4j依赖,这一步不用太麻烦,直接打开工程目录下的build.gradle文件,把这两行注释了:

 3. 修改日志配置

打开这个文件:

把下面的都注释了:

 最开始这个也改下,只输出到控制台,我们是本地调试,能在idea的控制台看到日志就行,你们也可以根据自己需要调整:

 4. 启动zookeeper

在本地启动一个zookeeper进程

5. 配置启动参数

kafka启动入口是这个:

直接运行是启动不起来的,我们需要配置下启动参数:

程序参数就是config目录下的server.properties文件:

jvm参数是刚才配置的那个日志文件,我们可以在控制台打印日志:

6. 启动

验证

本地发条消息:

 消费消息:

 topic列表:

 看看idea输出的日志:

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐