Kafka 源碼解析與實戰

王亮

Kafka 源碼解析與實戰
  • 出版商: 機械工業
  • 出版日期: 2017-12-25
  • 定價: $474
  • 售價: 7.9 折 $374
  • 語言: 簡體中文
  • 頁數: 260
  • 裝訂: 平裝
  • ISBN: 7111584015
  • ISBN-13: 9787111584018
  • 相關分類: Message Queue

    • 立即出貨

買這商品的人也買了...

簡體館年度書展｜現貨2書79折3書75折 詳見活動內容 »

簡體館年度書展｜現貨2書79折3書75折 詳見活動內容 »

相關主題

商品描述

本書系統介紹Kafka的實現原理和應用方法，並介紹Kafka的運維工具、客戶端編程方法和第三方集成方式，深入淺出、圖文並茂、分析透徹。本書共10章，主要內容包括：第1章介紹Kafka誕生的背景和主要涉及目標。第2章介紹Kafka的基本組成、拓撲結構以及內部的通信協議。第3章介紹BrokerServer及內部的模塊組成。第4章介紹BrokerServer內部的九大基本模塊。第5章介紹Broker的控制管理模塊。第6章介紹Topic的管理工具。第7章從設計原則、示例代碼、模塊組成和發送模式四個方面介紹有關消息生產者的相關知識。第8章介紹兩種消費者：簡單消費者和高級消費者。第9章介紹Kafka的典型應用，包括與Storm、ELK、Hadoop、Spark典型大數據系統的集成。第10章介紹了一個綜合實例，描述Kafka作為數據總線在安防整體解決方案中的作用。

作者簡介

王亮 架構師，曾在華為擔任虛擬化技術工程師，後加入大華公司任分佈式數據庫系統架構師，研究興趣為分佈式存儲、分佈式數據庫、消息系統等。

目錄大綱

序
前言
第1章 Kafka簡介
1.1 Kafka誕生的背景
1.2 Kafka在LinkedIn內部的應用
1.3 Kafka的主要設計目標
1.4 為什麼使用消息系統
1.5 本章小結
第2章 Kafka的架構
2.1 Kafka的基本組成
2.2 Kafka的拓撲結構
2.3 Kafka內部的通信協議
2.4 本章小結
第3章 Broker概述
3.1 Broker的啟動
3.2 Broker內部的模塊組成
3.3 本章小結
第4章 Broker的基本模塊
4.1 SocketServer
4.2 KafkaRequestHandlerPool
4.3 KafkaApis
4.3.1 LogManager
4.3.2 ReplicaManager
4.3.3 OffsetManager
4.3.4 KafkaScheduler
4.3.5 KafkaApis
4.4 KafkaHealthcheck
4.5 TopicConfigManager
4.6 本章小結
第5章 Broker的控制管理模塊
5.1 KafkaController的選舉策略
5.2 KafkaController的初始化
5.2.1 Leader狀態下KafkaController的初始化
5.2.2 Standby狀態下KafkaController的初始化
5.3 Topic的分區狀態轉換機制
5.3.1 分區狀態的分類
5.3.2 分區狀態的轉換
5.3.3 PartitionStateMachine模塊的啟動
5.4 Topic分區的領導者副本選舉策略
5.4.1 NoOpLeaderSelector
5.4.2 ……
5.4.3 ReassignedPartitionLeader-Selector
5.4.4 PreferredReplicaPartition-LeaderSelector
5.4.5 ControlledShutdownLeader-Selector
5.5 Topic分區的副本狀態轉換機制
5.5.1 副本狀態的分類
5.5.2 副本狀態的轉換
5.5.3 ReplicaStateMachine模塊的啟動
5.6 KafkaController內部的監聽器
5.6.1 TopicChangeListener
5.6.2 AddPartitionsListener
5.6.3 PartitionsReassignedListener
5.6.4 ReassignedPartitionsIsr-ChangeListener
5.6.5 PreferredReplicaElection-Listener
5.6.6 BrokerChangeListener
5.6.7 DeleteTopicsListener
5.7 Kafka集群的負載均衡流程
5.8 Kafka集群的Topic刪除流程
5.9 KafkaController的通信模塊
5.1 0 本章小結
第6章 Topic的管理工具
6.1 kafka-topics.sh
6.1.1 createTopic
6.1.2 alterTopic
6.1.3 listTopics
6.1.4 describeTopic
6.1.5 deleteTopic
6.2 kafka-reassign-partitions.sh
6.2.1 generateAssignment
6.2.2 executeAssignment
6.2.3 verifyAssignment
6.3 kafka-preferred-replica-election.sh
6.4 本章小結
第7章 生產者
7.1 設計原則
7.2 示例代碼
7.3 模塊組成
7.3.1 ProducerSendThread
7.3.2 ProducerPool
7.3.3 DefaultEventHandler
7.4 發送模式
7.4.1 同步模式
7.4.2 異步模式
7.5 本章小結
第8章 消費者
8.1 簡單消費者
8.1.1 設計原則
8.1.2 消費者流程
8.1.3 示例代碼
8.1.4 原理解析
8.2 高級消費者
8.2.1 設計原則
8.2.2 消費者流程
8.2.3 示例代碼
8.2.4 原理解析
8.3 本章小結
第9章 Kafka的典型應用
9.1 Kafka和Storm的集成
9.1.1 Storm簡介
9.1.2 示例代碼
9.2 Kafka和ELK的集成
9.2.1 ELK簡介
9.2.2 配置流程
9.3 Kafka和Hadoop的集成
9.3.1 Hadoop簡介
9.3.2 示例代碼
9.4 Kafka和Spark的集成
9.4.1 Spark簡介
9.4.2 示例代碼
9.5 本章小結
第10章 Kafka的綜合實例
10.1 安防大數據的主要應用
10.2 Kafka在安防整體解決方案中的角色
10.3 典型業務
10.3.1 車輛人臉圖片數據的入庫
10.3.2 視頻數據的入庫
10.3.3 數據延時的監控
10.3.4 數據質量的監控
10.3.5 布控統計
10.3.6 容災備份
10.4 本章小結

類似商品