KAFKA 理論與實戰
曾慶躍
- 出版商: 電子工業
- 出版日期: 2026-08-01
- 售價: $468
- 語言: 簡體中文
- 頁數: 244
- ISBN: 712153083X
- ISBN-13: 9787121530838
-
相關分類:
Message Queue
下單後立即進貨 (約4週~6週)
相關主題
商品描述
Kafka是大數據應用開發中常用的消息中間件,具有緩沖消息、流量削峰的功能,也具有很強的擴展性,使消息的生產者與消費者解耦。Kafka具有強大的大數據技術生態,通過使用Kafka,開發人員可以輕松構建大數據相關的應用。本書共有10章,其中第1~2章主要介紹Kafka的核心概念、入門使用及常用的操作命令,第3~5章主要介紹生產者、消費者、broker的相關概念,第6~7章主要介紹Kafka與springboot集成、Kafka常見問題,第8章介紹了Kafka監控工具Kafka Eagle的安裝與使用方法、Kafka集群動態擴縮容的方法,第9章主要介紹了Kafka源碼閱讀環境搭建、Kafka源碼閱讀方法,第10章主要介紹了Kafka消息可靠性與生產調優的方法。本書既可以作為高等院校計算機專業學生學習Kafka消息中間件的指導用書,也可以作為對Kafka消息中間件感興趣的開發人員的參考書
目錄大綱
第1章 Kafka概述
1.1 Kafka是什麼
1.2 消息隊列
1.3 使用Kafka的幾個理由
1.4 Kafka的核心概念
1.4.1 主題
1.4.2 分區
1.4.3 副本
1.4.4 主題、分區、副本之間的關系
1.5 Kafka的使用初體驗
1.5.1 在Windows中單機安裝、使用Kafka
1.5.2 Kafka發送消息和消費消息
第2章 Kafka集群環境搭建
2.1 Kafka集群環境搭建過程
2.2 Kafka環境啟動
2.3 Kafka集群的使用
2.3.1 Kafka主題常用命令
2.3.2 Kafka生產者常用命令
2.3.3 Kafka消費者常用命令
2.3.4 Kafka消費者組常用命令
2.4 Kafka自帶性能測試工具的使用
2.5 Windows中的Kafka集群環境搭建
2.5.1 Windows中的Kafka集群環境搭建過程
2.5.2 Windows中的Kafka常用命令
2.5.3 Windows中的Kafka消費者組常用命令
第3章 Kafka生產者
3.1 生產者
3.2 生產者分區分配
3.2.1 partition
3.2.2 不 partition key
3.2.3 不 partition也不 key
3.3 生產者發送消息
3.3.1 攔截器
3.3.2 序列化器
3.3.3 分區器
3.3.4 應用示例
3.4 消息發送
3.5 Kafka事務
3.5.1 Kafka冪等性
3.5.2 Kafka事務api
3.5.3 Kafka事務應用場景
3.5.4 Kafka事務示例
3.6 生產者數據有序性
3.7 生產者數據可靠性
3.8 生產者亂序
第4章 Kafka消費者
4.1 消費者
4.2 消費模式
4.3 消費者組
4.4 消費者消費過程
4.5 消費者消費分區分配策略
4.6 消費者消費消息
4.6.1 反序列化器
4.6.2 攔截器
4.7 消費者偏移量
4.8 AR、ISR、OSR
4.9 HW、LEO
4.10 分區副本故障
4.11 消息的漏消費與重覆消費
4.12 消息有序性
4.12.1 消息生產有序
4.12.2 消息消費有序
4.13 消息消費的幾種方式
4.13.1 多線程消費
4.13.2 線程池消費
4.14 消費分區重平衡問題
第5章 Kafka broker
5.1 Kafka broker的位置
5.1.1 ZooKeeper在Kafka中的作用
5.1.2 ZooKeeper主要目錄的作用
5.2 消息存儲
5.2.1 log文件與index文件的關系
5.2.2 log文件與timeindex文件的關系
5.3 消息格式
5.4 Kafka消息保留機制
5.4.1 消息保留策略
5.4.2 消息清理策略
5.5 消息壓縮
5.6 控制器
5.7 broker端配置參數詳解
第6章 Kafka與Spring Boot集成
6.1 Spring Boot集成Kafka
6.2 監聽器消費Kafka消息
6.2.1 設置消費者數量
6.2.2 消費者手動提交偏移量
6.3 線程池消費Kafka消息
6.4 順序消費
6.5 重覆消費冪等處理
6.5.1 集成mybatis-plus
6.5.2 生成業務處理類
6.6 Kafka常用配置
6.6.1 生產者配置
6.6.2 消費者配置
6.6.3 broker端配置
6.7 Kafka使用綜合示例
6.7.1 生產者示例
6.7.2 消費者示例
6.8 Kafka與Flink集成
第7章 Kafka常見問題
7.1 消息重覆問題
7.2 消息丟失問題
7.3 消息積壓問題
7.3.1 消息積壓判斷方法
7.3.2 消息積壓產生的原因
7.3.3 消息積壓解決方法
7.3.4 消息積壓示例
7.4 提高消費者消費能力問題
7.5 消息重覆消費問題
7.5.1 消息重覆消費判斷方法
7.5.2 消息重覆消費的原因
7.5.3 消息重覆消費解決方法
7.6 消息消費有序性問題
7.6.1 單分區單線程有序消費
7.6.2 單主題多分區多線程有序消費
7.6.3 單分區線程池有序消費
7.7 消息 一次消費
7.8 Kafka環境隔離問題
第8章 Kafka Eagle監控
8.1 安裝MySQL與Kafka Eagle
8.1.1 安裝MySQL數據庫
8.1.2 安裝Kafka Eagle
8.2 使用Kafka Eagle監控數據
8.3 集群增加broker節點
8.3.1 增加節點
8.3.2 topic分區重分配
8.4 集群減少broker節點
8.4.1 刪除節點
8.4.2 分區分配情況
8.5 增加分區
8.6 分區副本的增加和減少
8.6.1 分區副本的增加
8.6.2 分區副本的減少
第9章 Kafka源碼閱讀
9.1 Kafka源碼閱讀環境搭建
9.1.1 Scala安裝
9.1.2 Gradle安裝
9.1.3 ZooKeeper安裝
9.1.4 Kafka源碼下載
9.2 Kafka生產者源碼
9.2.1 生產者測試入口
9.2.2 生產者初始化
9.2.3 生產者組裝待發送的消息
9.2.4 生產者發送消息
9.3 Kafka消費者源碼
9.3.1 消費者測試入口
9.3.2 消費者初始化
9.3.3 消費者消息拉取
9.3.4 消費者消息拉。著
