1.1 IDEA 环境搭建

在 windows 环境下使用 IDEA 搭建 kafka 的源码阅读与测试环境,具体教程可以参考:

鉴于 UCAS 的 CS 课程大多是偏向底层操作系统和体系结构,软件层面上的类似的环境配置经历不多,此番操作过程堪称曲折,总结基本流程与注意点如下:

  1. 安装 IDEA,版本为 IntelliJ IDEA Community Edition 2023.2.4 (注:此处为伏笔,如果想要使用IDEA 提供的依赖分析矩阵、生成 UML 图等优质功能,还是得找个满血版)

  2. 从 github 上获取 1.1 版本的 kafka 源码

  3. 安装 JDK 1.8,并配置环境变量

  4. 安装 Gradle 4.8 ,关于网络换源问题,在依照上述教程修改后依然显示 time out,解决方法是在源码build.gradle 文件中添加阿里云相关配置:

  1. 安装 Scala 2.11.12

  2. 安装 Zookeeper 3.4.9,配置 zoo.cfg 文件

  3. 为 IDEA 安装Scala插件,这一步可以直接在 IDEA 提供的 plugin 中搜索安装,以避免插件版本问题

  4. 利用 IDEA 打开 Kafka源码,注意正确的打开方式是使用 build.gradle 文件导入新项目,否则会默认使用 Maven 作为构建工具

  5. 配置 IDEA 相关环境,启动编译

到这一步为止,kafka的本地编译环境就算是搭建完成了,依照教程剩余的内容可以完成其启动和测试,其中需要注意的点有:

  1. 提示 core 模块缺少 slf4jjar ,解决方式是在 build.gradle 文件中找到 project(’:core’) 并添加相关依赖

  2. 在进行测试时保证 zkServer.cmd 进程在后台正确运行

  3. 在 IDEA 环境中测试 topic 功能,需要通过配置 Run Configuration 的方式来达成类似终端中使用脚本文件的效果,这意味着应该依次运行 kafka、createTopic、producer、consumer 配置

最终在生产者端口写入消息,可以发现消息被正常消费:

[UCAS] Hello Kafka!

大功告成,kafka,启动!

Last updated