《Apache Kafka2.0入門與實踐》是2019年9月清華大學出版社出版的圖書，作者是[美]勞爾·埃斯特拉達。
基本介紹
- 中文名：Apache Kafka2.0入門與實踐
- 作者：[美]勞爾·埃斯特拉達
- 譯者：張華臻
- 出版社：清華大學出版社
- 出版時間：2019年09月
- 定價：69 元
- ISBN：9787302534952
內容簡介,圖書目錄,
內容簡介
本書詳細闡述了與Apache Kafka 2.0相關的基本解決方案，主要包括配置Kafka、訊息驗證、訊息增強、序列化、模式註冊表、Kafka Streams、KSQL、Kafka Connect等內容。此外，本書還提供了相應的示例、代碼，以幫助讀者進一步理解相關方案的實現過程。
本書既可作為高等院校計算機及相關專業的教材和教學參考書，也可作為相關開發人員的自學教材和參考手冊。
圖書目錄
第1章 配置Kafka 1
1.1 Kafka簡介 1
1.2 安裝Kafka 2
1.2.1 在Linux中安裝Kafka 4
1.2.2 在macOS中安裝Kafka 5
1.2.3 安裝Confluent Platform 7
1.3 運行Kafka 8
1.4 運行Confluent Platform 8
1.5 運行Kafka代理 10
1.6 運行Kafka topic 13
1.7 命令行訊息生產者 16
1.8 命令行訊息消費者 17
1.9 使用kafkacat 18
1.10 本章小結 19
第2章 訊息驗證 20
2.1 企業服務匯流排 20
2.2 事件建模 21
2.3 配置項目 23
2.4 從Kafka中讀取數據 26
2.5 向Kafka中寫入數據 29
2.6 運行處理引擎 31
2.7 驗證器的Java編碼 33
2.8 運行驗證 35
2.9 本章小結 38
第3章 訊息增強 39
3.1 獲取地理位置 40
3.2 增強訊息 42
3.3 析取貨幣價格 44
3.4 利用貨幣價格充實訊息 46
3.5 運行引擎 48
3.6 析取天氣數據 51
3.7 本章小結 52
第4章 序列化 53
4.1 Kafka物聯網公司Kioto 53
4.2 項目配置 54
4.3 Constants類 56
4.4 HealthCheck訊息 58
4.5 Java PlainProducer類 59
4.6 運行PlainProducer 62
4.7 Java PlainConsumer類 63
4.8 Java PlainProcessor對象 64
4.9 運行PlainProcessor 67
4.10 自定義序列化器 68
4.11 Java CustomProducer類 69
4.12 運行CustomProducer 70
4.13 自定義反序列化器 71
4.14 Java CustomConsumer類 72
4.15 Java CustomProcessor類 73
4.16 運行CustomProcessor 75
4.17 本章小結 76
第5章 模式註冊表 77
5.1 Avro簡介 77
5.2 定義模式 78
5.3 啟動Schema Registry 79
5.4 使用Schema Registry 80
5.4.1 在值主題下註冊一個新的模式版本 80
5.4.2 在鍵主題下註冊一個新的模式版本 81
5.4.3 將現有的模式註冊至新的主題中 82
5.4.4 列出全部主題 82
5.4.5 通過全局唯一ID查詢模式 82
5.4.6 列出註冊於healthchecks-value主題下的全部模式版本 83
5.4.7 查詢註冊於healthchecks-value主題下的模式版本1 83
5.4.8 刪除註冊於healthchecks-value主題下的模式版本1 83
5.4.9 刪除最近註冊於healthchecks-value主題下的模式 83
5.4.10 刪除註冊於healthchecks-value主題下的全部模式版本 84
5.4.11 檢測模式是否已註冊於healthchecks-key主題下 84
5.4.12 模式兼容性測試 84
5.4.13 獲取頂級兼容性配置 84
5.4.14 全局更新兼容性需求條件 85
5.4.15 更新healthchecks-value主題下的兼容性需求條件 85
5.5 Java AvroProducer 85
5.6 運行AvroProducer 89
5.7 Java AvroConsumer類 91
5.8 Java AvroProcessor類 92
5.9 運行AvroProcessor 94
5.10 本章小結 95
第6章 Kafka Streams 96
6.1 Kafka Streams簡介 96
6.2 項目配置 97
6.3 Java PlainStreamsProcessor類 98
6.4 運行PlainStreamsProcessor 101
6.5 Kafka Streams擴展 102
6.6 Java CustomStreamsProcessor類 103
6.7 運行CustomStreamsProcessor 104
6.8 Java AvroStreamsProcessor類 105
6.9 運行AvroStreamsProcessor 107
6.10 延遲事件處理 108
6.11 基本場景 109
6.12 延遲事件的生成 110
6.13 運行EventProducer 112
6.14 Kafka Streams處理程式 113
6.15 運行流處理程式 115
6.16 流處理程式分析 116
6.17 本章小結 117
第7章 KSQL 118
7.1 KSQL簡介 118
7.2 運行KSQL 119
7.3 使用KSQL CLI 120
7.4 利用KSQL處理數據 122
7.5 寫入topic中 123
7.6 本章小結 126
第8章 Kafka Connect 127
8.1 Kafka Connect簡介 127
8.2 項目配置 128
8.3 Spark流處理程式 129
8.4 從Spark中讀取Kafka 130
8.5 數據轉換 131
8.6 數據處理 133
8.7 從Spark中寫入至Kafka 133
8.8 運行SparkProcessor 135
8.9 本章小結 136
