Apache Kafka源碼剖析 ( 簡體 字) |
| 作者：徐郡明 | 類別：1. -> 程式設計 -> Kafka |
| 譯者： |
| 出版社：電子工業出版社 |  3dWoo書號： 46733
詢問書籍請說出此書號！【缺書】
NT售價： 445 元 |
| 出版日：5/1/2017 |
| 頁數：604 |
| 光碟數：0 |
|
站長推薦：   |
| 印刷：黑白印刷 | 語系： ( 簡體 版 ) |
| |
加入購物車  │加到我的最愛
(請先登入會員) |
| ISBN：9787121313455 |
| 作者序 | 譯者序 | 前言 | 內容簡介 | 目錄 | 序 |
| (簡體書上所述之下載連結耗時費功, 恕不適用在台灣, 若讀者需要請自行嘗試, 恕不保證) |
| 作者序： |
| 譯者序： |
前言：這是一個數據大爆炸的時代，互聯網成為了數據傳播的主要載體。大數據處理平臺在現代化的互聯網公司進行商業決策、規劃發展、市場拓展等方面扮演著越來越重要的角色。Kafka作為大數據平臺的重要組件之一，受到越來越多的設計人員和開發人員的青睞，Kafka的社區也變得越來越活躍，Kafka本身的架構設計、應用場景也得到了長足的發展。
Kafka最開始由LinkedIn設計開發，并于2011年年初開源，2012年10月成為Apache基金會的頂級項目。目前Kafka為越來越多的分布式大數據處理系統提供支持，其中也包括著名的Apache Spark，LinkedIn、Netflix、Uber、Verizon、網易、美團等互聯網公司也選擇以Kafka為基礎搭建其大數據處理平臺或消息中間件系統。隨著Kafka的應用場景越來越豐富，用戶對Kafka的吞吐量、可擴展性、穩定性和可維護性等有了更多的期許，也有很多開發人員參與到Kafka的開發建議制定和代碼提交中。在Kafka 0.10.X版本中出現了很多令人欣喜的新功能，本書深入剖析了Kafka 0.10.X的內部設計和實現細節。
本書以Kafka 0.10.0版本源碼為基礎，深入剖析了Kafka的各個模塊的實現，包括Kafka的生產者客戶端、消費者客戶端、服務端的各個模塊以及常用的管理腳本。筆者對Kafka設計的理解和經驗分享也穿插在了剖析源碼的過程中，希望讀者能夠通過本書理解Kafka的設計原理和源碼實現，同時也學習到Kafka中優秀的設計思想以及Java和Scala的編程技巧和規范。
如何閱讀本書
由于本書的篇幅限制，本書并沒有詳細介紹Kafka源碼中涉及的所有基礎知識，例如Java NIO、J.U.C包中工具類的使用、命令行參數解析器的使用等，為方便讀者閱讀，筆者僅介紹了一些必須且重要的基礎知識。在開始源碼分析之前，希望讀者按照第1章的相關介紹完成Kafka源碼環境的搭建，并了解Kafka的核心概念，這樣也可以有更好的學習效果。
本書共五章，它們互相之間的聯系并不是很強，讀者可以從頭開始閱讀，也可以選擇自己感興趣的章節進行學習。
第1章是Kafka的快速入門，其中介紹了Kafka的背景、特性以及應用場景。之后介紹了筆者在實踐中遇到的一個以Kafka為中心的案例，并分析了在此案例中選擇使用Kafka的具體原因和Kafka起到的關鍵作用。最后介紹了Kafka中的核心概念和Kafka源碼調試環境的搭建。
第2章介紹了生產者客戶端的設計特點和實現細節，剖析了KafkaProducer攔截消息、序列化消息、路由消息等功能的源碼實現，介紹了RecordAccumulator的結構和實現。最后剖析了KafkaProducer中Sender線程的源碼。
第3章介紹了Kafka的消息傳遞保證語義并給出了相關的實踐建議，還介紹了Consumer Group Rebalance操作各個版本方案的原理和弊端。最后詳細剖析了KafkaConsumer相關組件的運行原理和實現細節。
第4章介紹了構成Kafka服務端的各個組件，依次分析了Kafka網絡層、API層、日志存儲、DelayedOperationPurgatory組件、Kafka的副本機制、KafkaController、GroupCoordinator、Kafka的身份認證與權限控制以及Kafka監控相關的實現。本章是Kafka的核心內容，涉及較多的設計細節和編程技巧，希望讀者閱讀之后有所收獲。
第5章介紹了Kafka提供的多個腳本工具的使用以及具體實現原理，了解這些腳本可以幫助管理人員快速完成一些常見的管理、運維、測試功能。
如果讀者在閱讀本書的過程中，發現任何不妥之處，請將您寶貴的意見和建議發送到郵箱xxxlxy2008@163.com，也歡迎讀者朋友通過此郵箱與筆者進行交流。
致謝
感謝電子工業出版社博文視點的陳曉猛老師，是您的辛勤工作讓本書的出版成為可能。同時還要感謝許多我不知道名字的幕后工作人員為本書付出的努力。
感謝張占龍、張亞森、楊威、劉克剛、劉思等朋友在百忙之中抽出時間對本書進行審閱和推薦。感謝林放、米秀明、星亮亮、王松洋、褚洪洋、曾天寧、葛彬、趙美凱、顧聰慧、孫向川、段鑫冬、彭海蛟、趙仁偉等同事，幫助我解決工作中的困難。
感謝馮玉玉、李成偉，是你們讓寫作的過程變得妙趣橫生，是你們讓我更加積極、自信，也是你們的鼓勵讓我完成了本書的寫作。
最后，特別感謝我的母親大人，謝謝您默默為我做出的犧牲和付出，您是我永遠的女神。
徐郡明 |
內容簡介：本書以 Kafka 0.10.0 版本源碼為基礎，針對 Kafka的架構設計到實現細節進行詳細闡述。本書共5 章，從 Kafka 的應用場景、源碼環境搭建開始逐步深入，對 Kafka 的核心概念進行分析介紹，對 Kafka 生產者、消費者、服務端的源碼進行深入的剖析，最后介紹 Kafka 常用的管理腳本實現，讓讀者不僅從宏觀設計上了解 Kafka，而且能夠深入到 Kafka 的細節設計之中。在源碼分析的過程中，還穿插了筆者工作積累的經驗分析和對 Kafka 設計的理解，希望能夠讓讀者可以舉一反三，不僅知其然，而且知其所以然。 本書旨在為讀者閱讀 Kafka 源碼提供幫助和指導，讓讀者更加深入地了解 Kafka 的運行原理、設計理念，讓讀者在設計分布式系統時可以參考 Kafka 的優秀設計。本書的內容對于讀者全面提升自己的技術能力有很大幫助。 |
目錄：第1章 快速入門
1.1 Kafka簡介
1.2 以Kafka為中心的解決方案
1.3 Kafka核心概念
1.4 搭建Kafka源碼環境
本章小結
第2章 生產者
2.1 KafkaProducer使用示例
2.2 KafkaProducer分析
2.2.1 ProducerInterceptors＆ProducerInterceptor
2.2.2 Kafka集群元數據
2.2.3 Serializer＆Deserializer
2.2.4 Partitioner
2.3 RecordAccumulator分析
2.3.1 MemoryRecords
2.3.2 RecordBatch
2.3.3 BufferPool
2.3.4 RecordAccumulator
2.4 Sender分析
2.4.1 創建請求
2.4.2 KSelector
2.4.3 InFlightRequests
2.4.4 MetadataUpdater
2.4.5 NetworkClient
本章小結
第3章 消費者
3.1 KafkaConsumer使用示例
3.2 傳遞保證語義（Delivery guarantee semantic）
3.3 Consumer Group Rebalance設計
3.4 KafkaConsumer分析
3.4.1 ConsumerNetworkClient
3.4.2 SubscriptionState
3.4.3 ConsumerCoordinator
3.4.4 PartitionAssignor分析
3.4.5 Heartbeat分析
3.4.6 Rebalance實現
3.4.7 offset操作
3.4.8 Fetcher
3.4.9 KafkaConsumer分析總結
本章小結
第4章 Kafka服務端
4.1 網絡層
4.1.1 Reactor模式
4.1.2 SocketServer
4.1.3 AbstractServerThread
4.1.4 Acceptor
4.1.5 Processor
4.1.6 RequestChannel
4.2 API層
4.2.1 KafkaRequestHandler
4.2.2 KafkaApis
4.3 日志存儲
4.3.1 基本概念
4.3.2 FileMessageSet
4.3.3 ByteBufferMessageSet
4.3.4 OffsetIndex
4.3.5 LogSegment
4.3.6 Log
4.3.7 LogManager
4.4 DelayedOperationPurgatory組件
4.4.1 TimingWheel
4.4.2 SystemTimer
4.4.3 DelayedOperation
4.4.4 DelayedOperationPurgatory
4.4.5 DelayedProduce
4.4.6 DelayedFetch
4.5 副本機制
4.5.1 副本
4.5.2 分區
4.5.3 ReplicaManager
4.6 KafkaController
4.6.1 ControllerChannelManager
4.6.2 ControllerContext
4.6.3 ControllerBrokerRequestBatch
4.6.4 PartitionStateMachine
4.6.5 PartitionLeaderSelector
4.6.6 ReplicaStateMachine
4.6.7 ZooKeeper Listener
4.6.8 KafkaController初始化與故障轉移
4.6.9 處理ControlledShutdownRequest
4.7 GroupCoordinator
4.7.1 GroupMetadataManager
4.7.2 GroupCoordinator分析
4.8 身份認證與權限控制
4.8.1 配置SASL/PLAIN認證
4.8.2 身份認證
4.8.3 權限控制
4.9 Kafka監控
4.9.1 JMX簡介
4.9.2 Metrics簡介
4.9.3 Kafka中的Metrics
4.9.4 Kafka的監控功能
4.9.5 監控KSelector的指標
第5章 Kafka Tool
5.1 kafka-server-start腳本
5.2 kafka-topics腳本
5.2.1 創建Topic
5.2.2 修改Topic
5.3 kafka-preferred-replica-election腳本
5.4 kafka-reassign-partitions腳本
5.5 kafka-console-producer腳本
5.6 kafka-console-consumer腳本
5.7 kafka-consumer-groups腳本
5.8 DumpLogSegments
5.9 kafka-producer-perf-test腳本
5.10 kafka-consumer-perf-test腳本
5.11 kafka-mirror-maker腳本
本章小結 |
| 序： |
