|
|
Java电子书：Kafka权威指南 格式 pdf 电子书 PDF 电子书 Java吧 java8.com
) ~% b% i) t1 v; d
, S! f; \& {5 z* ]7 o# B
. `5 T+ i: H8 p0 Y+ P" w3 C: F9 ?编号：mudaima-P0295【Java吧 java8.com】$ x& }8 @- Z I3 P4 P& @
( a& Q2 `! t: N) k
" ]$ H* J5 r9 l5 s: p: L, V9 J( s( z# [& J2 R
Java电子书目录：第 1 章 初识Kafka 12 v/ q$ }- k, M5 f) _
6 C, l! F- n. \1 P, d
1.1 发布与订阅消息系统 1
3 X' M0 Z( k# d- P
6 T0 Z8 e j1 `1.1.1 如何开始 2$ O, g \& Q5 X) \5 _, p
2 x6 O$ ?; p& u& {( D7 ^1.1.2 独立的队列系统 3
8 }9 e3 ^* f) m0 I( O! ]' l4 \, Y
8 y; `# S* l; p0 [1.2 Kafka登场 4
?0 O, e; ~+ p. \; ^8 A/ @
4 J0 K0 p7 ]* Z2 w" Z0 S2 D1.2.1 消息和批次 40 j: j* O$ |. Y- A0 s5 h( {7 r7 E$ F
) k; _% [2 U$ g/ f! h) s# o1.2.2 模式 41 \5 t( c( \; }' \/ x0 l
1 T4 L+ K& B& x1.2.3 主题和分区 5
5 A: K# A# x0 v" W" I: ^7 Y
) o4 H. A9 ~+ k: R" n1.2.4 生产者和消费者 5
6 q7 o# _) F. G' s! }6 }( l/ @+ V o9 O1 W& I }
1.2.5 broker和集群 6
1 _0 x* {- |! `2 _8 i# |; Z& @$ p2 o8 m
1.2.6 多集群 7
: {8 J7 y( c2 j, W2 D2 G2 |/ g: I4 b+ h- x. D8 x" x& m4 z
1.3 为什么选择Kafka 8
7 S, z4 W$ @1 ]4 g+ [1 P6 Z4 S4 b9 o/ d2 u. ?, m$ B( n' H% Q
1.3.1 多个生产者 8
9 H% `2 }2 T0 p% v ?" U* [1 _# |& v) p- X( h2 H
1.3.2 多个消费者 8
! H9 j7 u0 A. ~0 H- @+ x3 b) E( ^' b! }
1.3.3 基于磁盘的数据存储 9& a) ~$ p7 [( W" H
$ j3 ?# o0 E' H" W1.3.4 伸缩性 94 p1 U, Y# @7 w7 C
; i5 a3 p3 \( Z5 o2 m1.3.5 高性能 9. @2 H. s' z3 ~& G3 ~/ T8 _6 H
4 D; O) a0 L+ O4 D, p6 \# l, L
1.4 数据生态系统 9! |2 `- m) u, l' o. |& `# X, J3 e5 a
! K9 P( i+ M: _& _+ G0 ~% G1.5 起源故事 11
* A* f( U ?# w d% |# p$ a
. U9 ], C- U- {- A" Z6 D2 n1.5.1 LinkedIn的问题 119 ], T. S" U9 H& G
5 O- b8 G5 F9 {5 W, A, i' D* |
1.5.2 Kafka的诞生 12
+ P0 @1 e% k+ {# T$ x) R* x& ]' k W
+ W& M9 D9 U2 r t1.5.3 走向开源 12
- i5 i- ^! f# ^$ o/ W" F# v5 e
4 | _1 ]+ G; N7 V# O, }3 w1.5.4 命名 13
7 v; l- o7 K0 u/ R9 ?2 }$ ?* U' M) P7 d0 ]" G( u9 L
1.6 开始Kafka之旅 13- z8 S$ A8 G$ z$ |% U/ ^+ d: @- Q
) x9 N+ }/ h6 {2 \2 y4 Y
第 2 章 安装Kafka 141 w; m R; R! a' Y- r9 |
1 _, K2 f1 {/ y! g& J8 a3 O2.1 要事先行 148 R# |" ]9 G% J! t+ W
/ e) v- p) B) J6 b4 N* L) e) J2.1.1 选择操作系统 14
: H# n' b$ `5 i Q4 M* N
# r: s$ S7 p- d2 s0 d' G' a2.1.2 安装Java 14
" \ y; I' B" Y" k1 ?7 S/ q; H7 z8 F
/ w6 I/ s( J: g. g0 T2.1.3 安装Zookeeper 15
/ w3 b3 t* c7 m3 B, b! K) Z: K" V# x1 {" f Z
2.2 安装Kafka Broker 17
( V$ H. }# b5 S
! \* `, O6 H! a; W5 e" h2.3 broker配置 18
- x7 } O" U( u; f5 B0 a) f! n
7 Y0 q7 ?8 z8 A; \2.3.1 常规配置 18% C+ P# z( o- ^- x
. a2 E; E" }8 F9 \% M" V$ v2.3.2 主题的默认配置 19
" h; \$ e& W9 G( C" f' D$ A6 N6 c1 A' H; s' s; _. G. Q: m( y& }
2.4 硬件的选择 23
- w+ ]) ?2 p# @" z+ {2 C ?- S6 Q+ q6 X V( u
2.4.1 磁盘吞吐量 23
+ D9 q- T, D, s5 ?9 |0 L+ b$ @8 ?; N# a' r
2.4.2 磁盘容量 23
( P1 @6 n# h" @# j2 d
0 Q& @# B+ K5 j! T2.4.3 内存 23# e; k% D+ q# `3 q; c, d) [1 x3 j. R6 _
' w @4 k5 c( U8 ]6 O4 B6 h. K2.4.4 网络 24" S& { P+ i# A2 T
- I# i3 {" G& j, B; M: n
2.4.5 CPU 249 C% r3 d* s2 [4 b; Y a7 m
9 x7 {; ?9 @( D6 `6 M, i' B2.5 云端的Kafka 24; a$ o: ~2 [+ D P6 Z0 @1 D$ F, J
. u/ d6 [' ^9 p
2.6 Kafka集群 24
1 g8 K( }. ~2 Q7 M# s% |" a1 y7 o8 i9 A' J
2.6.1 需要多少个broker 25$ l. x! V- L' f+ J M0 m
( n: @% W* T1 o# a/ J; @
2.6.2 broker 配置 25
- T/ D3 a& H! w6 a( J- |+ ^7 i9 }7 ?5 {
2.6.3 操作系统调优 26% M9 D6 v9 C, g: G2 u/ l& {* b
# S- m' {: {3 n5 g8 b n
2.7 生产环境的注意事项 28
& e* h6 c5 m: {% ]& Y+ y3 D" y# \
1 Q- U, x ^1 t2.7.1 垃圾回收器选项 28( W; T0 J# F2 J! J* U! d0 [# c
0 P, P0 W8 T$ B- m1 @
2.7.2 数据中心布局 29' g" T6 F2 P" L5 _4 B% ]! J
' f' u* F* C4 h! d) n- ?( m$ A
2.7.3 共享Zookeeper 29
6 g3 m" @( u8 A2 Z4 _8 U3 w% r; ?9 X( z3 d" E5 ?7 s7 l- V! S
2.8 总结 30. Y/ x6 h9 W7 X- x! b, D
3 P! e/ D0 Q7 v4 T# N' B- b第 3 章 Kafka生产者——向Kafka写入数据 31 f' {5 W/ L# `9 g
9 {" |- L4 f5 j' Y6 Y9 A3.1 生产者概览 324 t4 q$ @2 ^1 |8 z
?) u1 r1 X5 c$ @9 f# h- c3.2 创建Kafka生产者 33
0 w3 v0 u9 c: w2 W" a# [3 S7 I9 g, t
# P' {$ I8 D9 Z3.3 发送消息到Kafka 34
, W5 G9 l% C+ d* m6 P
( M2 v) Y k' l7 R/ {' r- q3.3.1 同步发送消息 35; b4 {9 Q# p t1 L2 V W
& W5 t3 \9 q5 l/ S3.3.2 异步发送消息 35$ p; v) h K: k( k
3 c* P/ b/ J: ?& q O1 F
3.4 生产者的配置 36, L6 e* C$ V* S, _4 M- e5 t
8 \3 C0 \3 ]& _/ q2 Z; [# m
3.5 序列化器 39
/ b. F6 a: P5 F9 i
: @- [! H& N, A$ j, u2 s3.5.1 自定义序列化器 39, {7 [4 D# t0 N& K: [0 W
+ G! o7 a: K9 H/ ^6 m- X( P
3.5.2 使用Avro序列化 41; `$ y+ J8 m% X4 g
1 I5 c9 E4 Q0 O I
3.5.3 在Kafka里使用Avro 42
1 F; {( z/ i" g" o: |# O8 x9 O& k3 f5 Y
3.6 分区 45
) M6 Q9 u( M/ Q2 b9 I5 \- |
( m; h. ~! Q8 y3.7 旧版的生产者API 46) `. a4 p* d' h5 M
% w3 |3 H: L- f1 G" e" B/ k3.8 总结 47
4 E( d7 t3 r* p0 ^ Z c
1 ?1 v2 a1 ~) f2 D0 B. q) ?第 4 章 Kafka消费者——从Kafka读取数据 48
9 K0 x% L( [6 h; A; K" y* p4 z
+ a6 S; g& j8 O6 B* q5 E; m4.1 KafkaConsumer概念 48/ W, x6 @3 R+ |# j, t$ N0 \$ V
/ @# Q8 {6 u& v8 y9 j( D S4.1.1 消费者和消费者群组 48
Q: V9 d3 p2 w S4 z! t+ Z8 b7 Z' X" P# e2 d! v6 [# d+ a8 m( d
4.1.2 消费者群组和分区再均衡 51
9 x! O) X. R* F6 _: S g7 w4 q5 |# F% A1 g3 ?; `& W
4.2 创建Kafka消费者 52
7 T1 S: i! U O& w% H/ m8 N$ g8 I4 k& I$ u5 ]
4.3 订阅主题 53
9 B( C/ C1 I k, N& p" v) g9 y' W& f8 K; C0 c7 N2 ^: y
4.4 轮询 53
/ G5 x$ n. u' m" n5 o3 \0 O5 t5 y4 A
4.5 消费者的配置 55/ G9 A/ m. ], U: _" u) a
, ]1 W1 I+ [) t8 q2 H! X2 k) h
4.6 提交和偏移量 57/ w+ D9 C, y0 K$ B) l
3 L: J, q$ ?* T0 F" E) T' c4.6.1 自动提交 58
1 u) f8 s* V J1 m! r" x/ B6 D6 b9 K1 A5 k; S% J/ M
4.6.2 提交当前偏移量 59
1 Z1 i! a' O9 ]0 s! J9 S( v+ r. B9 A, A- \$ [# Z
4.6.3 异步提交 59$ I6 b8 h8 k, A# o, }5 d$ ]2 w+ c
4 O& d+ [, U& {) q) }
4.6.4 同步和异步组合提交 61
2 p9 ^% i7 O+ _. R" ^) o6 j/ Z$ l0 ^: ~5 T& b7 G" |2 F
4.6.5 提交特定的偏移量 61% j; q% }9 V/ s* l$ B
. h/ f8 O2 U0 m! ~4.7 再均衡监听器 62" z; ~+ [0 t6 Q, |; o0 I5 S
( @' t: H" E* y; N
4.8 从特定偏移量处开始处理记录 64
! _" f1 _6 h2 N- @; c& ^. ]5 ~7 ?2 _9 s+ l
4.9 如何退出 66
9 }6 _0 w" ]: A+ S3 q6 p- [ T! ]
4.10 反序列化器 67
7 o/ x: {. D- \! s- X
# |3 r/ d* j6 q7 H9 _( b+ ^+ g& m6 K4.11 独立消费者——为什么以及怎样使用没有群组的消费者 71
! f, V0 y2 c6 I( c0 c; j% Q, j5 @
% v4 O- O4 d6 n! Y4 x1 g+ x4.12 旧版的消费者API 71- `( N! t& d/ }# w/ [4 g
: h: V6 X8 [5 u7 }. b4.13 总结 72* u5 A5 e0 T( z& k- p
0 J. o' H* U8 v( {% Z" L; t4 p
第 5 章 深入Kafka 734 T1 f; N( s9 H& k& w2 R, s
7 w% s1 K8 O |. q' a! H
5.1 集群成员关系 731 |4 g, F' F8 z6 h
' Y# c5 }* R% k
5.2 控制器 74& |% ]2 q1 y# s4 c* u
9 r/ W; k; g; ]4 J2 E- W$ ?
5.3 复制 74* D( @8 I- P4 ^; k- N
& G$ y% C3 y4 D5 `) y+ U, |
5.4 处理请求 768 A9 O4 ]0 }; T! e7 G# ]
& i! L7 V" F1 h% r# c3 J
5.4.1 生产请求 78/ {% V6 }2 F/ v, }: o; r
5 _9 {! I% |3 z3 k" y5 I5.4.2 获取请求 78
$ `3 B4 U2 K. L6 l3 `
3 l- L& P* O8 t! l) U6 i5.4.3 其他请求 80
9 t( C+ ^- [ E( ]. ~9 j3 O8 S! u* |
5.5 物理存储 815 P0 k9 U+ ?2 u$ f9 r2 R
3 k8 i; o/ E9 [ M3 r+ X5.5.1 分区分配 81
* ?$ E- ~: S" T: x. v7 m& t8 A+ ~; N( A2 u
5.5.2 文件管理 82
6 W) Y' R) k' G5 Q. \' x3 y" g5 X' ?. o* Z
5.5.3 文件格式 838 E+ y$ n# x% `, M- u) M( x2 Q0 d j
4 N1 v2 [1 D6 b. Z5 L) z
5.5.4 索引 84
6 }( D8 L* l* U( m# z' j* t
0 Y) X9 P4 ]! k, s" E X5.5.5 清理 84
4 `6 R# K- v# Q& m8 I0 @' |2 z+ G# C
5.5.6 清理的工作原理 84' r; b5 W. U9 W/ V/ `0 x5 V D6 E3 M
( }1 D5 d/ w2 ]( e' s5.5.7 被删除的事件 86' k/ z" j/ F- H; a# p
; m9 j3 j* F, _5 {' r" D7 h
5.5.8 何时会清理主题 86
3 o: f6 a. ?' C* r2 V
9 L- V# C( h3 f( o* M5.9 总结 861 d& b# U7 C# v1 I) n5 L7 i! O* L
3 t9 r: r' C. o5 e+ d7 ?3 n. M2 j- r
第 6 章 可靠的数据传递 87' H% Z5 ^* @2 e! h" X
8 i0 k2 Z) v1 d2 C) x0 y6.1 可靠性保证 87
5 X3 }0 F4 e; [% [# R- y! T
8 n% n+ c1 G* L# U: _3 u6.2 复制 88# A' x* k6 {( k! q# o. z! l
5 f i1 D& n9 V5 a6.3 broker配置 89
: z6 |- u, F. ~8 y1 u7 ], c
' J8 y- A2 B& j6.3.1 复制系数 894 ^+ ?5 h1 l8 s4 I3 k
# {/ Q4 L( |: ^% L
6.3.2 不完全的首领选举 90" |- V- L0 {7 p- G8 e
- A# |! b* b4 q) T8 [* N, n! E- r
6.3.3 少同步副本 91
5 v1 r) [8 h% D$ }! y' W4 i! q' F
8 P$ h$ G! p" l! r. y2 X4 i, j- f6.4 在可靠的系统里使用生产者 92
( l) H' A7 ` t- j* a. i. P; w) r7 o5 |" O: u% C& y" k) V
6.4.1 发送确认 925 S4 f1 y: g4 r& @" S
+ L z0 l& b4 s0 A4 w
6.4.2 配置生产者的重试参数 93+ }9 K9 i/ ^- M
- ]; F# p- H& w$ U1 z6.4.3 额外的错误处理 94
6 M4 r/ F- W+ [9 p. D3 E9 b
$ T* t$ O0 k' V6.5 在可靠的系统里使用消费者 94
, k z, [2 T" t2 P0 H. @6 b; s6 a; h
6.5.1 消费者的可靠性配置 95
, ]4 G, |' p, C' f$ \8 Z& ~4 D9 E" q- X" T- t; L- A
6.5.2 显式提交偏移量 95/ ?% c* A0 W5 f1 D' a
9 w0 U5 V8 U- B! N9 o* p u- N' m/ q
6.6 验证系统可靠性 97
* ~) ^3 F1 C' a3 Q2 f# p3 v& e$ c* x5 O. q0 }
6.6.1 配置验证 984 o f J9 ~" _. X) ^2 V% c( X
" }# M E0 \2 u
6.6.2 应用程序验证 98
( L9 f7 l2 g/ @( W' x
6 S$ e% b, [9 m% E4 p/ g2 v1 X6.6.3 在生产环境监控可靠性 99
$ q( }. @* u* c$ E4 Q3 B* f# u
' E' A0 H" T: C# m# W6.7 总结 1007 Y5 q6 f; g* D+ D; E7 s
$ z$ o" o; N3 S- i3 U2 c) ~
第 7 章 构建数据管道 101
3 ]: t G3 O. J+ k
1 K5 ~4 N4 k7 k* \$ ?, ?7.1 构建数据管道时需要考虑的问题 102+ g! n6 g2 r* k1 e9 Z: T2 @( w
" g( A6 l( }6 Z* y. x6 R; U
7.1.1 及时性 102
* p/ p( q# K# e; Q# i h) m
/ W9 f7 L% l& U# ^7.1.2 可靠性 102
4 p* |1 Q3 ~0 B- }6 P# }
3 P! o2 Y% X5 w( z# j$ E0 B7.1.3 高吞吐量和动态吞吐量 103
" K/ R M- Q3 Y- x0 N% J3 M' `: o9 U4 Z$ @/ z5 D, L! }; k5 W2 J
7.1.4 数据格式 1039 d" J1 j+ t8 u9 n2 D; V! Q. V
* h# D8 C# a! P7.1.5 转换 104
) T& ^6 t4 W# J+ T i
% N9 G, E F4 U7 n$ D7.1.6 安全性 104; @9 h. ]$ V* n4 g& f" J* m
1 ?6 ~" {4 N$ ]# B; X
7.1.7 故障处理能力 104
' I" g% Y5 M' @+ G6 \' h- R8 b6 q o) ]7 `) [3 l/ y$ ]
7.1.8 耦合性和灵活性 105! q& |8 \$ l2 U& Q+ J
' t) v1 |8 n- v: H' d7.2 如何在Connect API和客户端API之间作出选择 105
1 E$ F ?4 P' Y2 p, q5 @
( {+ s. w( A( R7.3 Kafka Connect 106
4 e9 {$ P. `! d# f/ [, Q3 S. s) }5 s7 o* R9 K5 ]. }% y5 @
7.3.1 运行Connect 106" t+ Q( q$ `! H/ O. G) `6 h& d
4 r7 g2 F6 d& n) K7.3.2 连接器示例——文件数据源和文件数据池 1079 c& U$ I$ |/ ~) S, b+ @: S
. m7 L* c2 a1 m7 h2 Y9 k) v$ L, [7.3.3 连接器示例——从MySQL到ElasticSearch 1092 L+ U# B$ Y$ U
. K: d+ c4 X; j: E+ `7.3.4 深入理解Connect 114
/ S% @/ n9 k" v
6 S5 | [# F$ P+ L# d7.4 Connect之外的选择 116, K7 L/ j5 p( B! J; v/ z
, k( x! b- K0 w3 }# w# V
7.4.1 用于其他数据存储的摄入框架 116
* k ^, {. m6 P# i( f* J% Q3 X7 e
7.4.2 基于图形界面的ETL工具 117. ~) E6 _- M" V% Q; z% {5 n, y
$ ~- ^" q+ V& K5 w7.4.3 流式处理框架 117
. b* X8 @" c: o3 ^ I' Q) Y2 M/ `: N( B& I# B( ~4 |4 u; Z( a# V7 K
7.5 总结 117
. D4 L- J( d. _* }, D3 l" d9 q+ M) r. ~0 T+ Z
第 8 章 跨集群数据镜像 118$ Q5 p3 \! x! G6 L& c9 ^1 J
, Z, F5 m8 C" ]; X8.1 跨集群镜像的使用场景 118
) H& T4 p" k$ }7 Z8 A
6 z: h3 K D7 |# d8.2 多集群架构 119
. F+ l$ s# z( u/ e& Q) i, s. W! y+ l8 ]9 ~4 l" f1 i# ?5 E) t
8.2.1 跨数据中心通信的一些现实情况 119
8 o8 A+ a% [8 _$ L8 C2 `: C3 ~7 d4 [% I# k# i# A9 T0 _# Q
8.2.2 Hub和Spoke架构 120
$ Z. N. m" q/ A8 S: L5 Y* z
9 l+ v% A3 Y. g0 u8 B/ ^! a8.2.3 双活架构 121( {: {! ~4 ~/ k: B1 w! E
5 A) Q5 H5 ]2 E8.2.4 主备架构 1233 b: h+ p/ Q2 @9 G4 S% K# V* K# c: ?
6 m; I3 G' j: ^2 M& W4 m+ Q8.2.5 延展集群 127
: a& y" \ ]; [4 c% [& S% P- T; {- w: H$ @. r) x4 ]
8.3 Kafka的MirrorMaker 128
6 C8 {4 K4 L4 }5 O' O4 h7 \. S* \1 t) q0 ~* q8 s
8.3.1 如何配置 129$ ~0 T/ Q( G. p) k
, X+ v$ b9 ~. _7 c: y* r9 ?# ~- F
8.3.2 在生产环境部署MirrorMaker 130
- B' C; [/ Z3 Z2 e s$ A8 B1 y9 P: p
8.3.3 MirrorMaker调优 132. n2 J( D n" Q: N1 R- |
4 w$ k: E5 B7 R% T; {8.4 其他跨集群镜像方案 134% ~/ @4 t: R$ W
3 g1 l" |# D) w8 z4 z' M8.4.1 优步的uReplicator 134+ M- G0 i: h; h2 S6 }1 T3 N( _
6 y& |7 c/ P% }- \" V- I2 |
8.4.2 Confluent的Replicator 135 y6 B0 ~2 r; f: ]- z2 L* A
1 f6 K; U2 i) Q4 P- ~. y
8.5 总结 135
& S5 J: r* Q. U+ O8 R" s
1 |+ P1 O z6 x/ ^# M% H4 c: y9 F第 9 章 管理Kafka 136
+ U- P0 |& n7 B2 Z; z9 z- S
`; _5 M( s+ z. H1 J9.1 主题操作 136
3 L: L" p; A9 t- g; `6 O
4 x0 H( V3 V$ d! @1 X9.1.1 创建主题 137
7 k7 t5 N9 Y" I4 W9 D3 n+ o* l C4 w- N; f8 L1 m3 A
9.1.2 增加分区 138
5 i0 t$ C1 \8 C) a( w- U& s& Z3 ?6 [7 C7 U' k
9.1.3 删除主题 138
1 H* M: x' N& E" h% ?
$ W* W3 Z8 A v& M2 C9.1.4 列出集群里的所有主题 1392 a) J# p* a( J x; m3 g5 Q/ ?
1 l) o! x1 x7 H9.1.5 列出主题详细信息 139* j5 H! G" M# l2 Z$ T
! Z2 X6 E; E$ A' I0 U3 q+ K9.2 消费者群组 140
+ e/ W& V" b7 K, Y& {# G8 {6 o5 @
( E! {9 Y* [ S {0 m) K3 t% h9.2.1 列出并描述群组 1406 G9 c: S' e& {4 F8 F6 A* b7 I" D
" ?: X9 h2 `6 q7 A$ j, N
9.2.2 删除群组 1426 r: I+ i4 v% a/ ~
- L* D3 Q& z q5 S z$ E, G9.2.3 偏移量管理 142
" G# B7 w N6 y3 k# {5 {# V! `# i J$ U+ ~! B( i
9.3 动态配置变更 143( I# S) \0 v: q# b2 M3 Z
- X5 i2 T7 {, U! Y" m" a
9.3.1 覆盖主题的默认配置 143; c/ B. G, E& C! o( w4 I5 i
1 W4 x6 K1 o: Q9.3.2 覆盖客户端的默认配置 1456 f' \' q b/ I
- s- c; q1 D( o. I/ O3 B$ J" k
9.3.3 列出被覆盖的配置 145/ \ t$ m4 F; f4 j! F
7 Z7 D" S- s# c* k; y- w
9.3.4 移除被覆盖的配置 1467 c# M( c- p5 V
$ l- z; m* J8 w7 {* i
9.4 分区管理 146
2 p# r; o8 j% y; d: z/ O: V5 d# i/ y) e% T6 q- N
9.4.1 的首领选举 146
& x. X- o7 O6 [ y- c" F# L
# j! O6 ^. G7 [8 z+ [! n9.4.2 修改分区副本 147
4 {$ y) p% l! u6 t: V' p+ ?/ q: N
5 f! W3 |. Z* @& q9.4.3 修改复制系数 150
$ d2 v1 Q& F8 A0 J/ h q+ U: k; u9 b; ?" e: i7 v+ u, a
9.4.4 转储日志片段 151
# N# M: z( L: ?* R5 M5 |$ ^+ V- y
* J4 s; E) ~, L+ g9.4.5 副本验证 152
. D3 c5 v0 K4 ~' S9 v" G+ E, ~7 a4 H% ^- ^# g
9.5 消费和生产 153) a' L$ p: s+ k2 \: \
4 [6 z1 p2 w0 c
9.5.1 控制台消费者 153
9 x, f$ `" P" g4 C# o# v- N: B( u4 o; I9 K+ T8 A3 |8 f
9.5.2 控制台生产者 1555 M, |6 I6 P/ v! Y$ U1 W9 |" C E
! x4 l4 w) B& s1 d1 _2 [9.6 客户端ACL 1571 F5 z1 c+ ~0 f7 T# x6 G
( ~8 f! R% _: X8 @1 F8 p& \7 x, p9.7 不安全的操作 157
/ f3 ~ _8 y% @# w
1 |5 \: @3 }' |7 Z9.7.1 移动集群控制器 157) u$ J& h5 Z- { Z
8 |3 P4 i' R% z9.7.2 取消分区重分配 157/ v7 B4 f9 `0 W7 y+ A' b) J. Y8 e
5 g6 q9 H1 {" l l; A
9.7.3 移除待删除的主题 158% j) H' ]* ?& E# ^ L( k. E7 v
3 o( P6 {. w; s' C9.7.4 手动删除主题 158' f/ d0 N# Y/ _. d
+ O+ b' ?" D/ S- K k5 |' [
9.8 总结 1594 F+ v/ y5 @1 L+ h6 u/ {
. Q# \8 i) z) r8 D$ {第 10 章 监控Kafka 160
- u8 ^: _0 T( e- [/ Z$ c% W2 F- R
9 z# n1 m8 q+ l3 Q10.1 度量指标基础 160# W2 f; J5 N# N5 S
6 z/ H3 o8 l. n10.1.1 度量指标在哪里 160) Q, ~- j; g4 x+ z7 H% K0 r0 a
% @9 h& S' Y- l7 A4 ^10.1.2 内部或外部度量 161* b0 |5 h7 C4 m* o! f0 X/ G/ o
0 W: D* A3 z# p' h
10.1.3 应用程序健康检测 161' J5 f5 E' \- O% u
$ O, G5 ^% K* V10.1.4 度量指标的覆盖面 161
D5 E7 X9 q$ N4 i" A) L: }& e5 Y/ b' S! }! ^0 a
10.2 broker的度量指标 162: {+ l; d7 X( X
, {; s1 _& }0 \. Y6 B3 h8 G10.2.1 非同步分区 1623 i5 O+ X* A% X$ I6 J
; i% _2 Q8 h" {7 ?/ k- d* K10.2.2 broker度量指标 166
8 _4 C. O# J% }6 B% D6 k6 M
( ~) m6 F# U( p2 L. W" q2 l3 {7 [8 _6 w10.2.3 主题和分区的度量指标 173
`* D1 o2 V/ _2 s y0 ^7 r
1 Z0 P% Z7 H, v1 W& b( M10.2.4 Java虚拟机监控 1748 U# k2 f e' H6 _5 Q
5 @2 d$ R, p0 J& k; g* I1 f& [10.2.5 操作系统监控 1750 c3 d4 o# h# W1 Q. S
$ m5 n" x: F8 ]4 q
10.2.6 日志 176# p" A5 j6 ~# \* n5 t
& Q3 T' o" Y5 v( ]! W10.3 客户端监控 177
4 }0 R1 W4 c; i: h
L! x7 C" e/ W- g) T D10.3.1 生产者度量指标 1778 N+ V6 T+ M, P
; Q- V' x& d) |$ H* ?3 K- ~' d10.3.2 消费者度量指标 179$ A6 z' u$ k1 ?. J
% q" R5 @* e4 o U; U10.3.3 配额 181
. i Z2 b2 b9 W F, A& h4 ^; Q. v
3 z' I# r+ \5 K, W Z6 t10.4 延时监控 182) c4 n8 M9 x- Y# `
" a Y/ ?) j2 F9 h
10.5 端到端监控 183
2 `5 I* c$ F& `3 U! I* c0 t5 a0 K) x. l. r+ m& M. X q
10.6 总结 183: c; d/ k0 ]: I
( j) U+ ^4 F' f第 11 章 流式处理 184
' I8 L) M0 Y- p" |7 X" V. f a: R8 w. s! M0 @! q7 `
11.1 什么是流式处理 185: ^. ?" c: D( U9 J# N4 H+ x
* M$ L6 L# @- N11.2 流式处理的一些概念 186: l$ p7 @, d+ W
6 |1 h% t; q6 Q11.2.1 时间 187
! }9 {' D$ e; A$ c
' d+ F( D* x/ s& o; }! C9 ^) ^% F. t11.2.2 状态 1884 l2 m3 J; k& v) V3 n
3 Q2 g: `0 F1 h# s$ R7 D6 z$ f11.2.3 流和表的二元性 188. G7 d, T" B! }7 K/ D0 C
6 b/ O# Q6 d% Y# V) y
11.2.4 时间窗口 1899 g& X- k( Z. {; _1 V: [& m
* e$ \) @! g6 N" x' \: T
11.3 流式处理的设计模式 190& V% ]) |1 }' j6 a
4 Z5 d3 ~( r- Z: P- n+ I" {
11.3.1 单个事件处理 191- u; n$ @# |5 _" M) N/ p8 c
4 Z9 p: e6 p. p$ x
11.3.2 使用本地状态 1916 K1 q# i6 _8 K/ t5 r
. z# I5 o/ W( S/ c5 j11.3.3 多阶段处理和重分区 193
; m" `- b7 }7 a1 ~& n: ]: g' q/ c! s: W* {$ j
11.3.4 使用外部查找——流和表的连接 193
8 @' y3 H/ g1 ], V# R' e8 A5 n- q9 k6 e* B
11.3.5 流与流的连接 195
' o2 [: t" A- E5 ?
) a2 b p. b4 U& @0 h11.3.6 乱序的事件 1953 Q0 I& n6 q% D. j! n! C! K
: |: I4 w: V5 Z q1 y4 c8 D$ G; O
11.3.7 重新处理 196
* G& {2 `: L, o( z: p0 a, f% d9 x$ x$ v. E: K% G! i! Q3 U
11.4 Streams示例 197' Z9 k1 p9 t) ]3 B" ~ b; }
2 q; q5 p( C) k& N& T, ~5 M7 O11.4.1 字数统计 197
y d ^) e* ?; t7 f- y1 q' v& G
11.4.2 股票市场统计 199
5 @' v5 }2 S# u1 U' Q6 ?
& S4 w, u0 z) F j; Y4 S0 G; ^8 b11.4.3 填充点击事件流 201, J3 w, ?, g/ ^% h
' a4 ]+ k/ N; G, ~11.5 Kafka Streams的架构概览 202# c% f4 m: m1 R. Y- j; H! c. ^ @
) f# j8 |5 D* e0 j V- x11.5.1 构建拓扑 202
, E4 O( b; y4 V& Kjava8.com
3 y$ z- \; g2 v2 D$ E11.5.2 对拓扑进行伸缩 203/ M7 M N6 @6 |3 f" M
# B2 g F4 y! y4 t4 R11.5.3 从故障中存活下来 205
4 `8 n% p2 q/ u1 S! Z+ u! X$ |' y* D5 S1 E: |
11.6 流式处理使用场景 205- b1 ^& L* {' E' p V+ I
: E* a9 c- S0 j" ~2 R! c0 b11.7 如何选择流式处理框架 206
9 c) W6 t" V& {* h$ E5 l* q) y: P% z; b3 I& N& B
11.8 总结 208. x0 w! \7 V2 V5 G3 R
3 \- K! J& R. I/ D附录A 在其他操作系统上安装Kafka 209
9 l8 u; @* W; {' Y: S% u8 U/ _
5 k: h0 v L# j: C作者介绍 214
Z" n& X/ J5 [, d" W* {3 `3 H7 p. F0 T4 t- `
封面介绍 2148 }5 y6 ^: o& u4 w
百度云盘下载地址(完全免费-绝无套路)：* \, _& ~7 S+ c# H& }0 B
|
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
3453 人阅读
|
20 人回复
|
2023-09-01
