最近开始对kafka contribute, 升级到最新的kafka, 突然发现 kafka 不能启动了, 特此记录.

  1. 启动类配置: core目录下 kafka.Kafka 类是启动入口, 可以先进行run创建启动文件
  2. 启动参数配置: Program Arguments: config/server.properties
  3. 环境变量配置: Environment Variables: kafka.logs.dir=${自己的路径}/log, 比如我配置的是: kafka.logs.dir=/Users/snow_young/deploy/log
  4. 日志配置: 将 config/log4j.properties 复制到 core/src/main/resources 目录下
  5. 将 compile libs.slf4jlog4j 复制到 build.gradle文件的 core 项目的 dependencies 中
  6. 启动zk: zkServer start. 我是 brew 安装的 zk, 启动比较方便
  7. 重新运行, 大功告成

注意

  1. kafka 加载到 intellij, 可能会存在索引缺失, intellij 的 import 路径标红的情况发生. 为了避免这样的情况发生, 我们需要进行索引构建
  2. 命令行使用 gradle idea 构建索引
  3. Intellij 更新缓存. 通过选项卡 File -> invalidate caches and restart, 进行一次重启