TA的每日心情 | 开心
9 小时前 |
|---|
签到天数: 324 天 [LV.8]以坛为家I
管理员
- 积分
- 10945
|
Java电子书：Kafka源码解析与实战 PDF 电子书 Java吧 java8.com" s* u& ~+ {3 G; k! n) [7 }. T
. x3 f2 x2 d0 z' m/ u, b C" ]
作者:王亮出版社:机械工业出版社出版时间:2017年12月
* e) Y3 B+ |( F- i, r0 J1 [1 d
( [5 |( q$ {) t. w编号：166-Java吧资源免费-X0111【Java吧 java8.com】
; \; H* w9 @. l% u% d$ |/ K: }6 M0 Y3 K( i* V
" Q: R! O) U/ X, \ d k! {9 D1 }1 U7 D
目录：
5 x9 v" M6 j }$ C第1章 Kafka简介 15 a9 F; X$ S9 N. k/ o4 l6 G- u
1.1 Kafka诞生的背景 1% h+ F0 I3 d6 x; j, P6 u
1.2 Kafka在LinkedIn内部的应用 30 a4 i& l( [9 u. j9 L
1.3 Kafka的主要设计目标 43 L0 j$ F$ |% h4 l
1.4 为什么使用消息系统 4
- m/ g% q2 Z b2 R6 b1.5 本章小结 5! o: I N; c' a* Y- _' G# ~
第2章 Kafka的架构 6( {/ \; R, A d9 u0 S' N. o
2.1 Kafka的基本组成 6' w; j% @2 d I6 _* g# H
2.2 Kafka的拓扑结构 8' Z1 ]% J$ ]8 N) m" \( e0 D
2.3 Kafka内部的通信协议 9
5 N/ K- [6 _. B/ |! ]2.4 本章小结 12
- ~& n- q k6 }第3章 Broker概述 133 e' [/ V% \, u7 E
3.1 Broker的启动 13
" A8 r7 O0 W/ d0 k8 d3.2 Broker内部的模块组成 153 K; F9 N4 S9 E2 Z2 s6 D6 \7 H
3.3 本章小结 18/ Y4 p- ?; \: Y% g) i
第4章 Broker的基本模块 196 k0 Q) O' |! u) G' m3 O! J" p% l" e
4.1 SocketServer 19$ T8 S" p! s$ r" [' O
4.2 KafkaRequestHandlerPool 254 g, C* Q+ K( K
4.3 KafkaApis 27* J, j% o! r( k) b+ n
4.3.1 LogManager 27! [7 k, ^& F! R2 r+ R
4.3.2 ReplicaManager 37' t- X4 k5 c' N
4.3.3 OffsetManager 47 m! Y4 B# ^5 ^0 Z2 c) v
4.3.4 KafkaScheduler 51' m* W, g2 l4 n5 [+ J
4.3.5 KafkaApis 52
% `: O4 [4 C6 ?; k4.4 KafkaHealthcheck 81/ }9 Y3 J) G& |
4.5 TopicConf?igManager 83
( c$ t& a' |% K, ? _4.6 本章小结 85
. a+ F4 B/ g" } | C第5章 Broker的控制管理模块 86
; Q* X( b2 V( H% G' X$ N" Y5.1 KafkaController的选举策略 867 _! E# q6 V6 T8 r9 a4 v
5.2 KafkaController的初始化 91- {' x `6 a! Z5 |" w$ w" I
5.2.1 Leader状态下KafkaController的初始化 91
8 W% E, w- ^7 ] S5.2.2 Standby状态下KafkaController的初始化 94
/ Y$ k' ]. K+ d% j2 |5.3 Topic的分区状态转换机制 95
- C9 ` m( K; D5.3.1 分区状态的分类 95! Q0 p6 j$ _ l1 ^" ^/ J
5.3.2 分区状态的转换 96# g# q6 R6 F& G i8 a8 X/ n, e2 J
5.3.3 PartitionStateMachine模块的启动 102$ l$ c8 R) P3 {# p$ I; s
5.4 Topic分区的领导者副本选举策略 103
1 ]: r- W; i$ u: h5.4.1 NoOpLeaderSelector 1040 X9 J Y( j, H3 Z, G
5.4.2 Off?linePartitionLeaderSelector 104
. Y) N. j9 f& ?* `% D- ~5.4.3 ReassignedPartitionLeader-Selector 106
4 O4 V( f, ^# p" n b' K5.4.4 PreferredReplicaPartition-LeaderSelector 107
7 a3 z! p4 F, k, y/ l; s5.4.5 ControlledShutdownLeader-Selector 108
0 q c- Y# |( D) R9 S J t5.5 Topic分区的副本状态转换机制 1091 p2 }% b8 ?7 p. ~, I! p
5.5.1 副本状态的分类 1108 I! t- }" t1 F& U9 }- V# B1 S
5.5.2 副本状态的转换 111
/ t' X; e8 N& z5 T( X5.5.3 ReplicaStateMachine模块的启动 117
# R2 y4 `, K" A. k! c) D5.6 KafkaController内部的监听器 1184 h& N! t+ ?# X/ C+ h0 Z
5.6.1 TopicChangeListener 119( ?5 \2 `0 z, T
5.6.2 AddPartitionsListener 121, e% Q. `) `$ c$ |5 n
5.6.3 PartitionsReassignedListener 122
8 W0 }% z2 u3 t0 ^5.6.4 ReassignedPartitionsIsr-ChangeListener 128
7 q( q8 y1 {3 f5.6.5 PreferredReplicaElection-Listener 1306 s- \: ~" P7 |2 Q- v
5.6.6 BrokerChangeListener 132
7 P+ A/ l& A# ]% _2 a: u. P5.6.7 DeleteTopicsListener 135
! U( e7 p2 M/ g" v- x5.7 Kafka集群的负载均衡流程 136
. u; A2 K5 r& {) {" H* R" o4 c' H* j. S5.8 Kafka集群的Topic删除流程 140
; J6 r# V- p" G8 W) @7 F: S5.9 KafkaController的通信模块 146
8 T+ j0 c# y7 p) t5.10 本章小结 150
( w! v; X! t; ~( h$ G) {第6章 Topic的管理工具 151
' \) c2 b% t+ ] L4 F6.1 kafka-topics.sh 151
?+ E, U& {* W7 j1 v; T* ~6.1.1 createTopic 1532 f' c( R" L+ ~
6.1.2 alterTopic 156
- ]1 j3 R7 F; a3 [: B; R6.1.3 listTopics 160
8 R' ?( J. P; r* O6.1.4 describeTopic 161( A0 Z3 E# q8 s
6.1.5 deleteTopic 163; |" \" P) C0 D; x1 ~
6.2 kafka-reassign-partitions.sh 164# {; }; \+ b$ b
6.2.1 generateAssignment 166
6 h1 }9 L) ^6 q* z5 y+ H/ U6.2.2 executeAssignment 167, \, ~2 {& P, }! z: `9 T2 b( q
6.2.3 verifyAssignment 170
; T; b9 Q2 ?$ |% z$ ]0 J6.3 kafka-preferred-replica-election.sh 1724 f( v, T7 Y: X$ d8 p( @
6.4 本章小结 175
; ?3 z* M! S7 i# O4 M第7章 生产者 176& E' M: y, ~* \( s3 X+ y
7.1 设计原则 176' [- X9 D- @4 P
7.2 示例代码 1763 g' P. j# n; _" w7 k* Q
7.3 模块组成 180/ H7 Z% I$ F; i! t
7.3.1 ProducerSendThread 180
& m& S) b0 m1 a6 p- G" q7.3.2 ProducerPool 182
. `8 [# X2 |7 n8 B6 K7.3.3 DefaultEventHandler 184, ^6 ^9 W; |# [5 W; _+ g9 o
7.4 发送模式 189
+ }) j# a: T; W' X5 i+ z# U7.4.1 同步模式 189
: }* L% \7 _2 A8 S/ w2 t6 ?' C0 X7.4.2 异步模式 189. E' I) J9 ~' r0 E
7.5 本章小结 1923 c& I/ s ]% B9 R3 k+ c' b
第8章 消费者 193
$ [' Y, |4 W. t, ~3 O9 o/ M) n8.1 简单消费者 1932 L) Z) L2 c9 M# v h
8.1.1 设计原则 193
( R8 o4 c6 }: Q# b" C8 `8.1.2 消费者流程 194
) G; F, F- n( t8.1.3 示例代码 195
; ~1 L9 D' X1 ~* H: v* n8.1.4 原理解析 200
: {3 z+ E$ J% M/ {" d# S8.2 高级消费者 202" e/ N# e7 R; d7 r5 n: X
8.2.1 设计原则 202
8 P/ }- \2 a0 W) G' t9 T8.2.2 消费者流程 203
4 Y6 f' K- s( D& P, R8.2.3 示例代码 2047 ^9 ]' K" ^$ c" _! W; T
8.2.4 原理解析 205
# |0 t" N! C, s D5 b% x, D8.3 本章小结 227
; X+ Z% c* T, ]第9章 Kafka的典型应用 228
# S( t8 @ _2 Z! t9 l: _9.1 Kafka和Storm的集成 228
`& O/ O F+ `( k9.1.1 Storm简介 228
( S, @2 T6 E: Q% g- X! j9.1.2 示例代码 230
* Y7 t5 \5 I3 ]% S: S' |9.2 Kafka和ELK的集成 235
+ }9 ~" {: I8 V; S# s9.2.1 ELK简介 2351 z& O& C. h1 D8 x
9.2.2 配置流程 2367 G$ T) V: I$ F
9.3 Kafka和Hadoop的集成 237* S3 O2 C% l- U* ], ~, V
9.3.1 Hadoop简介 237
4 Q- n4 Q# Z! n7 E1 m9.3.2 示例代码 239
' F$ m6 I0 [" p9.4 Kafka和Spark的集成 242% V* R* D5 K# o. j; l
9.4.1 Spark简介 242& @" P; E3 ]" Q& I4 R Y8 e& O$ M
9.4.2 示例代码 245+ }7 x+ l6 |* J1 m, x
9.5 本章小结 2471 N8 C4 }9 @# n! b8 C. N5 u$ K
第10章 Kafka的综合实例 2482 Y. |, H5 x4 ~' h
10.1 安防大数据的主要应用 2486 ?/ L$ k1 }* b9 d. i1 z& m4 v- d
10.2 Kafka在安防整体解决方案中的角色 249
8 v# N$ a' m$ P0 R8 X5 V' w10.3 典型业务 250 java8.com' i3 o' j! v: R& z& F
10.3.1 车辆人脸图片数据的入库 251+ ]& X, x% f O* g! Y+ R$ Z
10.3.2 视频数据的入库 252
3 I2 }/ v8 i6 j7 g7 [ R10.3.3 数据延时的监控 254! N1 b0 o" O( O+ ?: ?
10.3.4 数据质量的监控 256 l4 l% S$ I3 v: B. M; B2 G
10.3.5 布控统计 258
& g- u: ~6 g8 n* }% A6 L10.3.6 容灾备份 259
- L6 b: Q4 `# t. X/ l Y6 t10.4 本章小结 260
+ o8 [* o) c% W* ?" i0 c; \
( q, `4 i+ n0 |/ U/ H2 t& Q$ O: A: |8 M/ F, x" g9 Z
; u% K9 ?; f" X! ?
8 c- v* V0 v& J2 h4 k2 D! \0 U! w& w) A$ e$ i, Z: \: o
|
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
1461 人阅读
|
17 人回复
|
2023-12-29
