“10 小時(shí)”能收獲

• 快速上手 Kafka 生產(chǎn)者底層實(shí)現(xiàn)原理，輕松掌握 Kafka 各種新特性；

• 領(lǐng)略 kafka 源碼設(shè)計(jì)之美，系統(tǒng)掌握 Kafka 源碼實(shí)現(xiàn)邏輯，底層機(jī)制；

• 扛起 Kafka 架構(gòu)建設(shè)大旗，輕松應(yīng)對(duì)工作、面試中各種 Kafka 難題。

“實(shí)戰(zhàn)·系統(tǒng)”干貨

1、源碼閱讀準(zhǔn)備

• 基礎(chǔ)知識(shí)

• 源碼環(huán)境

• 源碼剖析思路介紹

• 從 demo 入手

2、Kafka 生產(chǎn)者實(shí)現(xiàn)流程

• Producer 核心流程介紹

• Producer 初始化

• Producer 端元數(shù)據(jù)管理

• Producer 源碼核心流程初探

• Producer 加載元數(shù)據(jù)

3、Kafka 生產(chǎn)者底層原理實(shí)現(xiàn)機(jī)制

• 分區(qū)選擇

• RecordAccumulator 封裝消息流程初探

• CopyOnWriteMap 數(shù)據(jù)結(jié)構(gòu)使用

• 把數(shù)據(jù)寫入對(duì)應(yīng)批次（分段加鎖）

• 內(nèi)存池設(shè)計(jì)

• Sender 線程運(yùn)行流程初探

• 一個(gè) batchs 什么條件下可以發(fā)送？

• 篩選可以發(fā)送消息的 broker

4、Kafka 生產(chǎn)者底層實(shí)現(xiàn)原理

• Kafka 網(wǎng)絡(luò)設(shè)計(jì)

• 如果網(wǎng)絡(luò)沒有建立會(huì)發(fā)送消息嗎？

• Producer 終于與 Broker 建立連接了！

• 生產(chǎn)者終于可以發(fā)送請(qǐng)求了！

5、Kafka 生產(chǎn)者源碼消息處理

• Producer是如何處理粘包、拆包問題的？

• 如何處理暫存狀態(tài)的響應(yīng)消息？

• 如何處理響應(yīng)消息？

• 消息發(fā)送完以后內(nèi)存如何處理？

• 消息有異常是如何處理的？

• 如何處理超時(shí)的批次？

• 如何處理長(zhǎng)時(shí)間沒收到響應(yīng)的消息？

6、Kafka 源碼總結(jié)

• 生產(chǎn)者源碼精華總結(jié)