图书介绍
Kafka源码解析与实战PDF|Epub|txt|kindle电子书版本网盘下载
![Kafka源码解析与实战](https://www.shukui.net/cover/67/34528476.jpg)
- 王亮编著 著
- 出版社: 北京:机械工业出版社
- ISBN:9787111584018
- 出版时间:2017
- 标注页数:260页
- 文件大小:101MB
- 文件页数:276页
- 主题词:分布式操作系统
PDF下载
下载说明
Kafka源码解析与实战PDF格式电子书版下载
下载的文件为RAR压缩包。需要使用解压软件进行解压得到PDF格式图书。建议使用BT下载工具Free Download Manager进行下载,简称FDM(免费,没有广告,支持多平台)。本站资源全部打包为BT种子。所以需要使用专业的BT下载软件进行下载。如BitComet qBittorrent uTorrent等BT下载工具。迅雷目前由于本站不是热门资源。不推荐使用!后期资源热门了。安装了迅雷也可以迅雷进行下载!
(文件页数 要大于 标注页数,上中下等多册电子书除外)
注意:本站所有压缩包均有解压码: 点击下载压缩包解压工具
图书目录
第1章 Kafka简介1
1.1 Kafka诞生的背景1
1.2 Kafka在LinkedIn内部的应用3
1.3 Kafka的主要设计目标4
1.4 为什么使用消息系统4
1.5 本章小结5
第2章 Kafka的架构6
2.1 Kafka的基本组成6
2.2 Kafka的拓扑结构8
2.3 Kafka内部的通信协议9
2.4 本章小结12
第3章 Broker概述13
3.1 Broker的启动13
3.2 Broker内部的模块组成15
3.3 本章小结18
第4章 Broker的基本模块19
4.1 SocketServer19
4.2 KafkaRequestHandlerPool25
4.3 KafkaApis27
4.3.1 LogManager27
4.3.2 ReplicaManager37
4.3.3 OffsetManager47
4.3.4 KafkaScheduler51
4.3.5 KafkaApis52
4.4 KafkaHealthcheck81
4.5 TopicConfigManager83
4.6 本章小结85
第5章 Broker的控制管理模块86
5.1 KafkaController的选举策略86
5.2 KafkaController的初始化91
5.2.1 Leader状态下KafkaController的初始化91
5.2.2 Standby状态下KafkaController的初始化94
5.3 Topic的分区状态转换机制95
5.3.1 分区状态的分类95
5.3.2 分区状态的转换96
5.3.3 PartitionStateMachine模块的启动102
5.4 Topic分区的领导者副本选举策略103
5.4.1 NoOpLeaderSelector104
5.4.2 OfflinePartitionLeaderSelector104
5.4.3 ReassignedPartitionLeader-Selector106
5.4.4 PreferredReplicaPartition-LeaderSelector107
5.4.5 ControlledShutdownLeader-Selector108
5.5 Topic分区的副本状态转换机制109
5.5.1 副本状态的分类110
5.5.2 副本状态的转换111
5.5.3 ReplicaStateMachine模块的启动117
5.6 KafkaController内部的监听器118
5.6.1 TopicChangeListener119
5.6.2 AddPartitionsListener121
5.6.3 PartitionsReassignedListener122
5.6.4 ReassignedPartitionsIsr-ChangeListener128
5.6.5 Pre ferredReplicaElection-Listener130
5.6.6 BrokerChangeListener132
5.6.7 DeleteTopicsListener135
5.7 Kafka集群的负载均衡流程136
5.8 Kafka集群的Topic删除流程140
5.9 KafkaController的通信模块146
5.10 本章小结150
第6章 Topic的管理工具151
6.1 kafka-topics.sh151
6.1.1 createTopic153
6.1.2 alterTopic156
6.1.3 listTopics160
6.1.4 describeTopic161
6.1.5 deleteTopic163
6.2 kafka-reassign-partitions.sh164
6.2.1 generateAssignment166
6.2.2 executeAssignment167
6.2.3 verifyAssigmnent170
6.3 kafka-preferred-replica-election.sh172
6.4 本章小结175
第7章 生产者176
7.1 设计原则176
7.2 示例代码176
7.3 模块组成180
7.3.1 ProducerSendThread180
7.3.2 ProducerPool182
7.3.3 DefaultEventHandler184
7.4 发送模式189
7.4.1 同步模式189
7.4.2 异步模式189
7.5 本章小结192
第8章 消费者193
8.1 简单消费者193
8.1.1 设计原则193
8.1.2 消费者流程194
8.1.3 示例代码195
8.1.4 原理解析200
8.2 高级消费者202
8.2.1 设计原则202
8.2.2 消费者流程203
8.2.3 示例代码204
8.2.4 原理解析205
8.3 本章小结227
第9章 Kafka的典型应用228
9.1 Kafka和Storm的集成228
9.1.1 Storm简介228
9.1.2 示例代码230
9.2 Kafka和ELK的集成235
9.2.1 ELK简介235
9.2.2 配置流程236
9.3 Kafka和Hadoop的集成237
9.3.1 Hadoop简介237
9.3.2 示例代码239
9.4 Kafka和Spark的集成242
9.4.1 Spark简介242
9.4.2 示例代码245
9.5 本章小结247
第10章 Kafka的综合实例248
10.1 安防大数据的主要应用248
10.2 Kafka在安防整体解决方案中的角色249
10.3 典型业务250
10.3.1 车辆人脸图片数据的入库251
10.3.2 视频数据的入库252
10.3.3 数据延时的监控254
10.3.4 数据质量的监控256
10.3.5 布控统计258
10.3.6 容灾备份259
10.4 本章小结260