kafka源码环境搭建

时间:2022-09-18 14:56:52

 

 

我搭建的是0.10.0.1版本

1、需要准备的又jdk1.8,scala2.1,gradle-3.1(这个下的好慢)、zookeeper。

2、ide推荐idea,eclipse的scala插件好多坑。

3、scala和gradle配个home和path就行了,配完查下版本好成功就好了,scala安装失败可能是jdk版本不对。gradle是maven的进化版。

4、kafka和zookeeper上apache官网下。

 

都装好的了,进入源码目录,执行gradle idea,

我执行的时候出个错

ScalaCompileOptions.metaClass.daemonServer = trueScalaCompileOptions.metaClass.fork = trueScalaCompileOptions.metaClass.useAnt = falseScalaCompileOptions.metaClass.useCompileDaemon = falsebuild。gradle加上这个就好了 等于会提示成功了,说明构建成功了,kafka是scala编写的,你要在kafka配个scala的插件导入项目kafka源码环境搭建kafka源码环境搭建

生产者和消费在clients下,服务端在core下。

启动之前要先启动zookeeper,kafka依赖这个,

还遇到个小问题,启动找不到日志,注意这个文件

kafka源码环境搭建

kafka源码环境搭建

这个目录没有你要见一个,把log4j的文件拖到里边,就有日志了。

 1、启动zookeeper,双击以下就行kafka源码环境搭建

 

 2、启动kafaka需要小配置一下

kafka源码环境搭建

把server放里边。

kafka源码环境搭建

出现这个就成功了,一启动电脑嗡嗡的,