搭建kafka2.0.0源码开发环境

一、先安装好 java 、scala、zookeeper、gradle，需要配置 JAVA_HOME、SCALA_HOME、ZOOKEEPER_HOME、GRADLE_HOME、PATH、CLASSPATH（java的）

二、下载 kafka 2.0.0 源码（ 要下载zip包，gz包里有些java文件有问题，是以.java0000664结尾 ）

https://github.com/apache/kafka/releases

三、使用eclipse 报很多错误，最好使用idea

intellij支持对每个project使用不同的sdk环境，不会读取系统的jdk、scala环境，需要自己配jdk、scala插件。

四、修改server.properties

log.dirs=D:\\sourcecode\\kafka\\kafka-2.0.0\\m
zookeeper.connect=127.0.0.1:2181/kk_wei

五、可选操作：修改 build.gradle 文件，设置在执行build时，跳过 带有 test 和 Test的 task

gradle.taskGraph.whenReady { taskGraph ->
  taskGraph.getAllTasks().findAll { it.name.contains('findbugsScoverage') || it.name.contains('findbugsTest') || it.name.contains('Test') || it.name.contains('test') }.each { task ->
    task.enabled = false
  }

六、为了减少麻烦，最好下载安装kafka的gradle.properties文件中指定的scala版本，否则，可能会有很多编译失败

七、配置 启动kafka.Kafka 时的program arguments为   D:\sourcecode\kafka\kafka-2.0.0\config\server.properties

八、解决无法打印log的问题

（1）将 slf4j-log4j12-1.6.1.jar log4j-1.2.16.jar 放到项目的类路径里，就可以在控制台打印log了

（2）要想把log打印到 log文件里，需要

1、创建目录 D:\sourcecode\kafka\kafka-2.0.0\logs  ，用于存放log文件

2、配置vm options（log4j会自动读取这两个参数，log4j.configuration会被LogManager类用来查找配置文件，kafka.logs.dir 是log4j.properties 中用到的参数）

-Dkafka.logs.dir=D:\sourcecode\kafka\kafka-2.0.0\logs
-Dlog4j.configuration=file:D:\sourcecode\kafka\kafka-2.0.0\config\log4j.properties

九、启动

先启动zookeeper，再在idea里启动 kafka服务器