国产一级片视频,2025日本三级片

內(nèi)容簡介

　　Apache Kafka是一個流行的分布式流平臺，充當消息隊列或企業(yè)消息傳遞系統(tǒng)。它用來發(fā)布和訂閱數(shù)據(jù)流，并在發(fā)生錯誤時以容錯方式處理它們。本書共13章，全面介紹使用Apache Kafka等大數(shù)據(jù)工具設(shè)計和構(gòu)建企業(yè)級流應用方面的內(nèi)容，包括構(gòu)建流應用程序的佳實踐，并解決了一些常見的挑戰(zhàn)，例如如何高效地使用Kafka輕松處理高容量數(shù)據(jù)。完成本書的學習后，讀者能使用Kafka設(shè)計高效的流數(shù)據(jù)應用程序。本書既適合Kafka初學者、大數(shù)據(jù)應用開發(fā)人員、大數(shù)據(jù)應用運維人員閱讀，也適合高等院校與培訓學校相關(guān)專業(yè)的師生教學參考。

作者簡介

　　蔣守壯，現(xiàn)就職于金拱門（中國）有限公司，擔任大數(shù)據(jù)卓越中心高級工程和平臺經(jīng)理，負責大數(shù)據(jù)平臺的架構(gòu)和產(chǎn)品研發(fā)。譯者擁有多年豐富的大數(shù)據(jù)生產(chǎn)實戰(zhàn)經(jīng)驗和產(chǎn)品研發(fā)能力，著有圖書《基于Apache Kylin構(gòu)建大數(shù)據(jù)分析平臺》。

圖書目錄

其他生產(chǎn)者配置 40
Java編程語言：Kafka生產(chǎn)者示例 42
常見的消息發(fā)布模式 44
最佳實踐 46
總結(jié) 48
第4章深入研究Kafka消費者 49
Kafka消費者內(nèi)部機制 50
理解Kafka消費者的職責 50
Kafka消費者API 52
消費者配置 52
訂閱和輪詢 54
提交和輪詢 56
其他配置 59
利用Java實現(xiàn)Kafka消費者 60
利用Scala實現(xiàn)Kafka消費者 62
Rebalance listeners 64
常用的消息消費模式 64
最佳實踐 67
總結(jié) 68
第5章集成Kafka 構(gòu)建Spark Streaming應用 69
Spark介紹 70
Spark架構(gòu) 70
Spark的核心 72
Spark生態(tài)系統(tǒng) 73
Spark Streaming 75
Receiver-based集成 75
Receiver-based approach的缺點 77
Receiver-based集成的Java示例 77
Receiver-based集成的Scala示例 79
Direct approach 80
Direct approach的Java示例 82
Direct approach的Scala示例 83
日志處理用例—欺詐IP檢測 84
Maven 85
生產(chǎn)者 89
Reader屬性 89
生產(chǎn)者代碼 90
欺詐IP查找 92
暴露Hive表 93
Streaming代碼 94
總結(jié) 97
第6章集成Kafka構(gòu)建Storm應用 98
Apache Storm介紹 98
Storm集群架構(gòu) 99
Storm應用程序的概念 100
Apache Heron介紹 101
Heron架構(gòu) 102
Heron topology架構(gòu) 103
集成Apache Kafka與Apache Storm - Java 104
示例 105
集成Apache Kafka與Apache Storm - Scala 110
用例—使用Storm、Kafka和Hive處理日志 114
生產(chǎn)者 118
生產(chǎn)者代碼 119
欺詐IP查找 122
Storm應用程序 123
運行項目 132
總結(jié) 133