一、對Kafka的認識

1.Kafka的基本概念

2.安裝與配置

3.生產與消費

4.服務端引數配置

二、生產者

1.客戶端開發

• 必要的引數配置
• 訊息的傳送
• 序列化
• 分割槽器
• 生產者攔截器

2.原理分析

• 整體架構
• 元資料的更新

3.重要的生產者引數

三、消費者

1.消費者與消費組

2.客戶端開發

• 必要的引數配置
• 訂閱主題與分割槽
• 反序列化
• 訊息消費
• 位移提交
• 控制或關閉消費
• 指定位移消費
• 再均衡
• 消費者攔截器
• 多執行緒實現
• 重要的消費者引數

四、主題與分割槽

1.主題的管理

• 建立主題
• 分割槽副本的分配
• 檢視主題
• 修改主題
• 配置管理
• 主題端引數
• 刪除主題

2.初識KafkaAdminCilent

• 基本使用
• 主題合法性驗證

3.分割槽的管理

• 優先副本的選舉
• 分割槽重分配
• 複製限流
• 修改副本因子

4.如何選擇合適的分割槽數

• 效能測試工具
• 分割槽數越多吞吐量就越高嗎
• 分割槽數的上限
• 考量因素

五、日誌儲存

1.檔案目錄佈局

2.日誌格式的演變

• v0版本
• v1版本
• 訊息壓縮
• 變長欄位
• v2版本

3.日誌索引

• 偏移量索引
• 時間戳索引

4.日誌清理

• 日誌刪除
• 日誌壓縮

5.磁碟儲存

• 頁快取
• 磁碟I/O流程
• 零拷貝

六、深入服務端

1.協議設計

2.時間輪

3.延時操作

4.控制器

5.引數解密

七、深入客戶端

1.分割槽分配策略

2.消費者協調器和組協調器

3._consumer_offsets剖析

4.事務

八、可靠性探究

1.副本剖析

2.日誌同步機制

3.可靠性分析

九、Kafka應用

1.命令列工具

2.Kafka Connect

3.Kafka Mirror Maker

4.Kafka Streams

十、Kafka監控

1.監控資料的來源

2.消費滯後

3.同步失效分割槽

4.監控指標說明

5.監控模組

十一、高階應用

1.過期時間(TTL)

2.延時佇列

3.死信佇列和重試佇列

4.訊息路由

5.訊息軌跡

6.訊息審計

7.訊息代理

8.訊息中介軟體選型

十二、Kafka與Spark的整合

1.Spark的安裝及簡單應用

2.Spark程式設計模型

3.Spark的執行結構

4.Spark Streaming簡介

5.Kafka與Spark Streaming的整合

6.Spark SQL

7.Structured Streaming

8.Kafka與Structured Streaming的整合

知其然不知其所以然，大廠常問面試技術如何複習？

1、熱門面試題及答案大全

面試前做足功夫，讓你面試成功率提升一截，這裡一份熱門350道一線網際網路常問面試題及答案助你拿offer

面試寶典+書籍+核心知識獲取：戳這裡免費下載！誠意滿滿！！！

2、多執行緒、高併發、快取入門到實戰專案pdf書籍

3、文中提到面試題答案整理

4、Java核心知識面試寶典

覆蓋了JVM 、JAVA集合、JAVA多執行緒併發、JAVA基礎、Spring原理、微服務、Netty與RPC、網路、日誌、Zookeeper、Kafka、RabbitMQ、Hbase、MongoDB 、Cassandra、設計模式、負載均衡、資料庫、一致性演算法 、JAVA演算法、資料結構、演算法、分散式快取、Hadoop、Spark、Storm的大量技術點且講解的非常深入