kafka学习全景图

服务端源码【基于Scala开发】

对应core目录

保存Broker所有源码

核心模块

文档相关

对应docs目录

保存kafka相关设计文档

示例相关

对应examples目录

保存Kafka demo示例

消息类处理模块

对应fenerator目录

主要根据Clients模块下的message json文件生成对应的java类

gradle模块

对应的gradle目录

kafka源码安装，保存为gradle的脚本和依赖包定义等相关文件

基准测试模块

一致性协议模块

流式处理模块

测试模块

工具类模块

Kafka Vagrant

代码规范，自动化检测

配置文件

脚本执行文件

客户端源码（基于java开发）

Connect组件源码（基于java开发）