通过分析Kafka的源码,深入了解Kafka
如果转载,请注明出处!
目前Kafka最新release的代码版本是2.4.1,此次源码分析基于此版本。 按照Kafka官方的核心模块进行源码学习。
- Java客户端源码分析
- 消息生产端源码分析
- 消息消费端
- 通用组件源码分析
- 服务器端源码分析
- 日志模块
- 请求处理模块
- Controller模块
- 状态机模块
- 延迟操作模块
- 副本管理模块
- 消费者组管理模块
- Streams组件源码分析
- kstream模块
- processor模块
- state模块
- 内部组件模块
- Connect组件源码分析
- 运行时模块
- API模块
- Connector模块
- 附录