源码下载

从kafka官网下载源码压缩包，以2.0.1版本为例，选择-src结尾的压缩包

kafka 2.0.1

依赖环境

kafka采用gradle构建，根据kafka的git提交记录，采用4.10.3版本构建，如果本地有别的gradle版本，可以尝试用sdkman这款工具来管理，一个命令即可切换版本
kafka使用scala语言开发，需要安装2.12版本的scala，同样的sdkman也可以快速安装
提交日志

修改配置及日志文件

修改config/server.properties文件相关参数

listeners=PLAINTEXT://localhost:9092
# 设置自己的目录路径
log.dirs=/Users/admin/app/other-kafka/kafka-2.0.1-src/logs
# 如果本地有别的kafka集群，设置zk的chroot
zookeeper.connect=localhost:2181/cluster_201

将config目录下的log4j文件复制到src/main/resources目录下，resources目录自己新建即可
移动log4j文件

导入IDEA

解压后导入IDEA中，IDEA会自动开始构建，等待IDEA下载依赖

相关问题

如果在编译的过程中出现以下错误

1	You can't map a property that does not exist: propertyName=testClassesDir

调整build.gradle中的依赖版本为以下版本
调整版本

1	Cause: org.jetbrains.plugins.gradle.tooling.util.ModuleComponentIdentifierIm Lorg/gradle/api/artifacts/ModuleIdentifier

如果报以上错误,请检查IDEA是否配置了正确的gradle 4.10.3版本的home路径(尤其是IDEA 2018版本)

遇到下载超时的jar包，可以到maven中央仓库下载jar，通过命名手动安装

举例：

1	mvn install:install-file -DgroupId=org.scala-lang -DartifactId=scala-reflect -Dversion=2.10.6 -Dpackaging=jar -Dfile=/Users/admin/scala/scala-reflect-2.10.6.jar

然后继续等待IDEA编译，等待期间多祈祷能下载下来…