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
现在可以开始跟踪调试了。