kafka 0.10.0.1 编译并导入idea调试

kafka 老版本的编译有很多的不兼容的问题,故记录之。

1. 准备

  • jdk1.8
  • gradle3.1
  • scala2.11.8
  • idea
  • zookeeper(单机集群都可以)


2. 下载源码

从 http://archive.apache.org/dist/kafka/ 下载 0.10.0.1 版本

3. 修改配置文件

3.1 对 gradle.build文件做如下修改:
3.1.1. 文件添加:

ScalaCompileOptions.metaClass.daemonServer = true
ScalaCompileOptions.metaClass.fork = true
ScalaCompileOptions.metaClass.useAnt = false
ScalaCompileOptions.metaClass.useCompileDaemon = false

3.1.2. 修改maven中央仓库仓库地址:
    搜索:repositories 定位, 把maven地址(mavenCentral())改为:

maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }


3.2. 修改gradle.properties:
    将scala版本修改为 2.11.8

3.3 创建log目录和 data目录,创建resources目录,将config下的log4j.properties文件放到resources目录下。

3.4. 修改文件

    修改 config/server.properties 文件中的 ${kafka.logs.dir} 都改到新创建的log目录。

    修改config/server.properties 文件中 log.dirs 改为新创建的 data目录。

4. 导入idea

4.1 导入idea

    使用IDEA 打开build.gradle文件,选择Open As Project

4.2 配置本地gradle

    导入进来之后,配置 Gradle 为本地的gradle

4.3 创建 Application

    截图如下:

 

4.4 启动 zookeeper

    如果不是默认的,需要修改 config/server.poroperties 文件的zookeeper.connect属性

4.5 运行 application

    运行成功截图如下:

    至此,可以在idea上看kafka源码, debug 源码啦。

    都说入门难,现在已经一只脚进门了,哈哈。

参考

https://www.cnblogs.com/set-cookie/p/9220120.html

原文地址:https://www.cnblogs.com/johnny666888/p/12349301.html