1.安装jkd、scala、gradle
- jdk版本1.8 （1.8.0_261）
- scaka版本 2.12.10 或者 2.13.3 kafak的核心代码使用scala编写的
- gradle版本5.6
安装完毕后，配置环境变量
上述版本都是kafka-2.5.1工程文件里配置的，最好编译时保存一直
2.官网下载kafka-2.5.1-src
3.intellij2019的gradle编译运行调试
3.1导入gradle工程
3.2修改build.gradle工程文件
编译出现的问题都是依赖关系源引起的，修改下载源地址是最简单快捷的解决办法。其他办法耗时费力还不一定解决。
3.3查看README.md进行编译
4.以连接器运行调试为例
查看connect-standalone.sh进步找到程序入口org.apache.kafka.connect.cli.ConnectStandalone
设置运行环境：
上述值是：-Dlog4j.configuration=file:E:\2020kafka\kafka-2.5.1-src\config\connect-log4j.properties
config\connect-standalone-dm.properties config\connect-dm-source.properties
现在可以开始跟踪调试了。