首页 > 其他 > 详细

kafka 0.10.0.1 编译并导入idea调试

时间:2020-02-24 12:44:08      阅读:128      评论:0      收藏:0      [点我收藏+]

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

kafka 0.10.0.1 编译并导入idea调试

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

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!