别再只会调 API，带你钻进 Kafka 源码深水区

大多数后端开发接触 Kafka，往往止步于“发布消息”和“消费消息”这两个操作。你习惯了把主题名、分区数、重试次数填进配置文件，就能跑通流程。但一旦生产环境出现消息积压、消费组崩溃或者乱序消费，你除了重启服务或怀疑是网络波动，根本找不到更深层的根因。这时候，光有框架层面的理解就是死胡同。本课程专门针对这种“调包侠”式的浅层认知进行补漏，不讲虚头巴脑的概念堆砌，直接切入 Kafka 核心源码，带你一层层剥开 `KafkaServer`、`Log`、`RequestHandler` 这些关键类的实现逻辑，让你真正看懂消息是如何在 Broker 端落盘、在 Controller 端协调、在 Client 端序列化与反序列化的全过程。

适合想从“会用”进阶到“会造”的中级开发者

这门课不建议完全零基础的新手直接硬啃，因为源码阅读需要一定的 Java 基础和对并发编程（如锁机制、线程池）的敏感度。如果你已经用过 Spring Cloud Stream 或 Spring Kafka 封装的高层 API，却对内部原理一知半解，比如不清楚 `OffsetCommit` 的具体执行流程，或者对 `Fetcher` 拉取消息的轮询机制感到困惑，那么这门课就是为你准备的。它适合那些在团队中需要负责中间件运维、排查线上故障，或者打算向高级后端、架构师岗位转型的工程师。课程从基础概念梳理开始，快速过渡到核心源码剖析，层层递进，确保你既有宏观架构视野，又有微观代码细节的掌控力，彻底填平“会用”与“精通”之间的鸿沟。

带着问题学，配合资料包实战演练

学完这门课，你应该能够独立回答：Kafka 如何处理 Leader 选举以保证高可用？ISR 机制在同步数据时具体是怎么工作的？消费组 Rebalance 的触发条件有哪些极端情况？当网络分区发生时，Broker 端的 `Fetch` 请求是如何处理的？以及自定义 Partitioner 算法后，消息落盘到底遵循什么规则？课程不仅讲原理，更强调落地。建议你在学习前，先搭建本地多节点 Kafka 集群，并配合提供的资料包进行复现。不要只是看视频，要动手修改源码中的某个判断逻辑，观察日志输出，或者在集群中模拟节点宕机、磁盘写入慢等场景，验证你对源码分析得出的结论是否成立。只有当你能在本地环境复现生产环境的复杂故障，并给出基于源码的解决方案时，才算真正掌握了这门课的精髓，具备独立解决 Kafka 疑难杂症的能力。

课程介绍

本课程来自马士兵，（高清完结版），是一门Kafka专题课。本课从Kafka基础到进阶，全面剖析Kafka源码，既有广度又有深度，学完基本上可以说是精通kafka了。

课程目录

├── 01 kafka初始，架构模型，角色功能梳理/
│ └── [1.5G] kafka初始，架构模型，角色功能梳理.mp4
├── 02 kafka集群搭建，topic+partition消费逻辑梳理/
│ └── [1.9G] kafka集群搭建.mp4
├── 03 基础开发及消费者提交维护offset不同粒度方式/
│ └── [1.9G] 消费者提交维护offset不同粒度方式.mp4
├── 04 kafka进阶，ISR,OSR,AR,LW,HW,LEO,ACK原理理论/
│ └── [1.6G] ISR,OSR,AR,LW,HW,LEO,ACK原理理论.mp4
├── 05 观察验证ISR弹性，时间戳索引，自定义offset便宜/
│ └── [1.9G] 观察验证ISR弹性，时间戳索引.mp4
├── 06 kafka之producer的参数，源码，原理剖析/
│ └── [1.8G] kafka之producer的参数，源码，原理剖析.mp4
├── 07 kafka 源码分析producer及通信原理/
│ └── [1.8G] kafka 源码分析producer及通信原理.mp4
├── 08 kafka 源码分析broker网络层通信原理/
│ └── [2.1G] kafka 源码分析broker网络层通信原理.mp4
├── 09 Replica源码分析数据同步原理及ACK细节(一）/
│ └── [2.3G] Replica源码分析数据同步原理及ACK细节1.mp4
├── 10 Replica源码分析数据同步原理及ACK细节(二）/
│ └── [2.4G] Replica源码分析数据同步原理及ACK细节2.mp4
├── 11 controller源码原理分析/
│ └── [1.9G] controller源码原理分析.mp4
├── 12 create-topic源码分析/
│ └── [1.3G] create-topic源码分析.mp4
├── 13 controller源码分析之协调metadata/
│ └── [1.7G] controller源码分析之协调metadata.mp4
├── 14 consumer源码分析coordinator/
│ └── [1.9G] consumer源码分析coordinator.mp4
├── 15 kafka源码Consumer全流程分析/
│ └── [1.9G] kafka源码Consumer全流程分析.mp4
├── 16 kafka事务原理导论及详解/
│ └── [1.8G] Kafka.mp4
├── 17 kafka connect原理剖析及源码分析/
│ └── [2.2G] kafka connect原理剖析及源码分析.mp4
├── 18 kafka总结及综合解决问题思路/
│ └── [947M] kafka总结及综合解决问题思路.mp4