开始之前
Kafka源码环境依赖Gradle、Scala和Zookeeper,所以需要提前将这些依赖安装好,由于这三个依赖的安装相对比较简单,所以在此不再赘述,只提供相应的链接!
Gradle安装
Scala安装
Zookeeper安装
安装好上述依赖后,依赖环境基本算是整完了,下面就开始着手Kafka源码环境的搭建!
源码下载
kafka官网提供了源码下载,本文使用的版本为kafka-0.10.2.1-src,也可以选择其他的版本,版本无所谓!
通过Gradle构建IDEA工程文件
kakfa下载完毕并解压缩到某路径下,cd到源码目录下,执行下面的命令即开始构建了,期间需要下载一些依赖包,可能需要等几分钟。
gradle idea
当构建日志中出现 Build Successful 字样时说明构建已经成功。文件目录结构大致如下图:
Screen Shot 2017-06-04 at 9.26.43 PM.png
IDEA打开kafka源码项目
使用idea打开构建完成的kafka源码项目,然后配置一个Application来启动kafka,具体如下图:
Screen Shot 2017-06-04 at 9.30.04 PM.png
启动Kafka
因为kafka依赖Zookeeper,所以在启动之前需要先将ZK启动,然后在启动kafka, 最终IDEA控制台出现如下内容说明Kafka已经启动成功!
Screen Shot 2017-06-04 at 9.34.11 PM.png
最后
整个过程相对来说比较简单,源码环境搭建好,就可以开始Kafka的源码之旅了!!!