|
|
Java电子书：Kafka权威指南 格式 pdf 电子书 PDF 电子书 Java吧 java8.com: y: M; z1 }! x- `. |
4 \+ L% o6 r2 \* J% r _. L
) v+ |( n/ S2 m! D a8 w+ A: x编号：mudaima-P0295【Java吧 java8.com】
( l5 w7 a' s0 ^+ D: g) S( ^* G
, ?5 Z! x9 f; w/ J) I s9 c+ o7 S( ~: V, s
( d2 K9 N4 X8 F" z- w
Java电子书目录：第 1 章 初识Kafka 1
2 V( J; Q+ j4 g3 `8 z9 p% T
% e8 V) z) A7 v8 u6 g8 [* J1.1 发布与订阅消息系统 1
0 v+ Z$ R5 g; B8 z, p9 a3 W' `7 N( l8 G: F5 a4 [! U5 f
1.1.1 如何开始 2# S! m+ U% o7 d1 F: y( g" w k/ U
& A! `8 o: m0 @ T5 [1.1.2 独立的队列系统 3
# Z2 ]4 Y( {# i3 _/ H
z9 V- s. @. A6 }1.2 Kafka登场 4
; _+ u6 ?% E X3 i
. |0 E- F3 }* l& A& ^' w1 p1.2.1 消息和批次 4
% _4 C$ ]. n$ @) D! D: u2 {
6 Y$ U1 v) M) q3 l! i+ l+ d8 F1.2.2 模式 40 F) T) h1 {$ j% z$ G2 Y6 |: L
) ]( E, Z) n F/ r
1.2.3 主题和分区 5
% r/ v' F: d1 J; N0 }8 i7 G7 m$ o. Y
6 Z. R; z \ t+ ]' `5 R6 K) B1.2.4 生产者和消费者 5
5 m; T0 H! X4 x5 Z6 A5 I) `& I7 a+ p% t. S3 P; G, z+ v# o, z
1.2.5 broker和集群 62 v$ E, b" c5 V# O
! i; \" N) h3 \4 o# L# v1.2.6 多集群 7' a1 \% X* D" |$ @& O7 P6 M6 x/ ?
# b% T" n0 E! }: g7 I: s1.3 为什么选择Kafka 8; j: v1 M( m3 I; \
7 X) ~8 j8 D5 d* A; @9 B
1.3.1 多个生产者 8
: ~* l' m' N3 s) W# O
6 ]* u; i1 s# e H* n1 [1.3.2 多个消费者 84 q# s0 l/ z& L% j6 s4 o
5 ~1 E- S! k5 @; ~$ e1.3.3 基于磁盘的数据存储 9
9 X6 }) Z5 s. X( u5 f! _
9 s# E0 G+ ~3 \1 c$ |; y2 D1.3.4 伸缩性 9( }6 Y: k, o+ j
$ k8 I2 `) \. o1 `1.3.5 高性能 9- q6 P" B5 [) r0 J- w' ]6 Q
9 g9 x3 o- ` T1 ~" U* Q- ~. y
1.4 数据生态系统 9
0 E' a4 ^( y" ]# r: `+ {1 \' O2 R" x# _9 `! n7 D
1.5 起源故事 11
) j3 n8 a' g, D! @( s& i$ Y. h& i" W( e0 f; F( }% k: Y
1.5.1 LinkedIn的问题 11
; R" H4 ^6 ]# j& [6 J3 [' j1 h' I9 D5 R
: F; U8 L1 ~ L1.5.2 Kafka的诞生 12+ v7 X; r* Q6 z R! s: _0 K
S4 A1 a5 A2 b5 b7 M- N
1.5.3 走向开源 123 ~# {1 m" F5 P% |4 P, Z+ u
( P* Y- @1 J, @& t1.5.4 命名 13
6 W8 E y* S" b5 M( ~4 n. ]
$ l6 L% c( q/ S: {+ j' _/ s1 ^1.6 开始Kafka之旅 13# B8 H5 E8 |1 F# @% c! T' u
& @0 W" v1 Z5 u4 _& h第 2 章 安装Kafka 14
5 R9 @7 d& V0 n& v- E
: V# p, @' y6 R$ @5 [2.1 要事先行 14
/ P/ i6 Q- h0 i( }' }, C' B
r2 |4 u- R- u8 L& ?7 y2.1.1 选择操作系统 14
) X& K. ~% P" g( [
, Z; _! o' ?( R2.1.2 安装Java 14& i T6 A; e' r
) p, n7 ~# `4 p( g& I& \
2.1.3 安装Zookeeper 15
* k6 o5 R" T0 \5 G. F
# {( ?5 {4 t" E& g& N1 G5 ?2.2 安装Kafka Broker 17
, x) u" F- _0 ^; Q* e/ r3 S
4 v' r }" V3 ]- c4 @2 e( V2.3 broker配置 18# v7 E. P1 [0 _5 T: b# G A( \ Z
: i% b' g3 y: o# q! I2.3.1 常规配置 18" G0 B6 _$ `, B9 Z
- Z7 s% i, y7 r6 J) i% V5 Y8 C
2.3.2 主题的默认配置 196 {/ \. C- J2 b
- q* f2 q- _0 i% n4 o2.4 硬件的选择 23( ` [* w, N9 i0 W6 q
) ^: s4 S: C+ E3 Z# T5 |$ B
2.4.1 磁盘吞吐量 235 I3 J2 n7 N, Y1 u: d
3 x/ z% _" Z) h7 e! Z* q& J
2.4.2 磁盘容量 23
0 t% t( W. i8 {5 _; M" O. @ c- k7 p6 }/ S% J3 N
2.4.3 内存 23
- d' Q. q* M6 Y# O; T6 I7 [% u* E5 L) ^9 R
2.4.4 网络 24
- Q0 v, V: r" a( t6 W4 Q2 i5 y7 K
" q% G" W+ d& P6 m2.4.5 CPU 24
3 i2 g- N# ~. u; s: h' y
, K& {! E, F- s2 T! n. _8 E2.5 云端的Kafka 24
0 w- L" w3 m R0 R9 A% b* O5 U3 P' _% @1 m; v" G6 s$ W, ~5 E
2.6 Kafka集群 24) Q ]3 ~5 ?/ T* F
7 O/ i! u5 f4 j u( C& A
2.6.1 需要多少个broker 250 {0 }' a, z: M9 j7 h; d
5 f6 @) S* R, n& c) |: O3 K
2.6.2 broker 配置 25
6 ` d* g6 Q5 S' p: z! f4 Z4 n2 A( z/ D6 X6 ? C/ S
2.6.3 操作系统调优 26( F' ^9 \( X& i* v e% ]
}& b; z3 m+ R8 y: Q
2.7 生产环境的注意事项 28) Y/ G N2 M/ t* d
' O1 c* y* S) P2 C8 w* `* Q1 v
2.7.1 垃圾回收器选项 28
. Q! O& A; `( V, x# d9 j
2 [- y1 C3 d# I; o8 D8 \8 V3 }2.7.2 数据中心布局 299 w6 t9 g+ ?2 d/ Y: p6 k. c
* K4 S: S* `- S9 I5 z) `2.7.3 共享Zookeeper 29/ q% v3 [' _9 { y, O. y" e
7 A- L- a; d/ h8 K0 v5 X2.8 总结 30- H, l- X+ |" F$ w
3 ?" n. e4 B" I' a6 L. @- m2 @第 3 章 Kafka生产者——向Kafka写入数据 31; M8 q; K p0 m( F* N; h
4 Q8 Z& e. Y' I& l5 W3.1 生产者概览 328 C% n6 J9 b0 R6 l$ h
! W" u5 b, s: @5 h5 [5 S0 H
3.2 创建Kafka生产者 33
& ^$ U6 R3 o. W% _" ~
0 }5 l; |# f* R1 S& S. Q3.3 发送消息到Kafka 34
" U2 r3 z; A8 W2 N* r( B4 Y& p8 w" U, |8 K% P4 r/ }9 n
3.3.1 同步发送消息 353 k' q/ B' f0 W( B( o) d- M
7 A8 t/ [) d5 P6 J' H f3.3.2 异步发送消息 35
, E/ H$ G8 s, d R) G# Y# d8 R2 f' C: T% M' o
3.4 生产者的配置 36
$ L: J* q) g8 H* V1 p$ [, Z. O2 l- h$ b* p
3.5 序列化器 39
* i9 b/ A2 P& h! u2 V* Z7 y( [7 z& n1 B. s" K. g3 D
3.5.1 自定义序列化器 39
& R/ d7 S% E2 G" S; L8 ^; G# x( [- f/ n0 \- p( p# E
3.5.2 使用Avro序列化 413 ]$ I" B5 J# g, Q- {2 D1 n; M
% B4 D0 f3 r1 w# {, O
3.5.3 在Kafka里使用Avro 42
: X/ A1 U d ^/ \, x% |5 x3 z$ U
9 g" c' v; z0 K3 B3.6 分区 45' }* E7 u3 }9 b! R; T+ B
. @; ?7 M3 w0 p- G. J3.7 旧版的生产者API 46
* d! U5 f3 p! e9 N/ ~3 d* T: h5 M. r0 H/ s6 m7 q' g
3.8 总结 47
* T9 e4 H" k2 z/ U+ U# k6 s6 \
+ S% {: b" c. G5 @第 4 章 Kafka消费者——从Kafka读取数据 48
+ u$ I9 E. ^0 y1 f+ ~, s. E+ ~/ z& F
4.1 KafkaConsumer概念 48; u5 L% o$ C, l$ ]1 i7 D5 F) @! u
7 m( V" {, ~9 j/ }4.1.1 消费者和消费者群组 48. ?5 j) Z. a" Q/ P0 c! e1 s# e
- M, J- O: N2 _3 b8 A8 B5 U
4.1.2 消费者群组和分区再均衡 510 U5 h2 r$ R. P4 u1 h, ~' q
9 {- t: L, \+ L9 b' |4.2 创建Kafka消费者 52
! i3 U8 Z _6 {" I0 [, V, {2 `: t5 D' F6 y0 ~9 g
4.3 订阅主题 53. S( t9 d% z0 o2 K5 e Z
& z7 i8 }' W: Y' P- N" k4.4 轮询 53
! S# U7 M' L% X9 G1 K( p' D1 e% x7 Y" \: ]- x/ Q' f$ D
4.5 消费者的配置 55
9 h7 ?" W! n6 m5 W) t8 \. `/ J
6 r: U8 J. L- m n. T4 {) W- G4.6 提交和偏移量 57
, u% ]5 v" [. K) l( b% n3 W! _- K0 v. `0 }4 o- y7 B
4.6.1 自动提交 58
F2 N9 O& g/ O- b4 @3 s' L; b, H7 }5 m7 [
4.6.2 提交当前偏移量 59* z+ `2 |% X$ ?+ } W( e% O
) H/ z+ n T$ l# d
4.6.3 异步提交 59" n3 U* R/ K, v6 f" v) C5 J: n, e
( L) c4 h1 y1 \! t! h/ T1 A7 C
4.6.4 同步和异步组合提交 61
a- M/ |3 e- d
$ Y2 H" T' i. s1 ~4.6.5 提交特定的偏移量 61
& Q" G, Z' l7 h$ d- ?( {% N6 X; [0 \$ |( @
4.7 再均衡监听器 62$ f$ k; ^: n/ p; u
6 L4 j& i3 p0 Q7 u5 x8 N( E4.8 从特定偏移量处开始处理记录 64
& E; m$ m* ~* I* U0 D, f- g
/ n; v1 h9 m' ^! C7 C ]- r4.9 如何退出 66) J, v% X& K4 d8 f( @
0 |# n4 u/ U9 v
4.10 反序列化器 67. m; E( v+ U1 E5 c
- ]+ V+ ~9 H V/ W1 {4.11 独立消费者——为什么以及怎样使用没有群组的消费者 718 H4 ~) S8 \3 T/ `1 D5 t
9 z4 r7 R& N* |' L4.12 旧版的消费者API 71. @$ X, Z$ z S& L" ]* Y- R( K
8 ]" M/ a7 J4 i
4.13 总结 72& u3 w: b7 j, U) f. y& e
! S7 O3 l# h; A) y/ w8 h5 o
第 5 章 深入Kafka 73
( j: {4 t# o) H" K6 x' R9 N) y) H( F. p: [# ^: e
5.1 集群成员关系 73
$ p1 u6 Q1 K+ j4 s1 E7 D
: Z# f: f( a- y1 L2 ~/ B5.2 控制器 74
2 u+ y4 J9 C5 M7 |- B- U+ c8 o# d+ e5 d3 O- r
5.3 复制 74
* |3 |) W/ D& ?; r: }
; p, o* |9 v- L0 e5.4 处理请求 76
# \; V0 U% P0 v) s/ t2 `4 x( F* |# G# t
5.4.1 生产请求 789 i# k- O9 q6 @, i' v- j
+ b) z- y5 y/ e5 i- C! @5.4.2 获取请求 78) G7 P) l# Z% g( N- |) R
1 Z; V3 R( M$ s% e( v5.4.3 其他请求 80+ m3 E- }8 a) c/ W M+ Y4 o) o9 {
1 n1 X ], w* W& a4 T/ b$ F
5.5 物理存储 81
! u/ B/ ?/ z9 O3 G4 K* F, U3 ^1 ~# F9 \) F; v/ w8 c2 w- e) H
5.5.1 分区分配 819 L" X1 T% p+ c6 ^1 \2 S: P: W2 H
5 w( j) R% Y& T9 ]2 O
5.5.2 文件管理 823 k6 A* Z4 s9 t, {, x% ]4 `1 c" z
* C4 N: e8 a. M; H5.5.3 文件格式 83
+ j7 ^- p8 b5 t, h! ~& c
0 N V. J% }3 H5.5.4 索引 843 V0 f4 {5 i7 ?1 e, ~4 @1 D4 k3 }$ l
& s4 U: ~4 C, `+ L: Z
5.5.5 清理 84" a( R4 V6 x2 d) o7 J
+ ?5 S9 W2 M M6 w% m
5.5.6 清理的工作原理 84
0 h4 z( U0 a) M, c. x9 Q
7 P6 ]# k' l: q5.5.7 被删除的事件 86
0 G) ~2 ^; @/ l
+ b P' Q" n! v, ? O5.5.8 何时会清理主题 86* q `$ J( F& D# S' H, I- e8 }/ n
7 ]& R- B0 @) Y7 X! l- H" q
5.9 总结 86( N% ?- \' m. M
! `! k9 D# d* K* m( d2 ]6 `第 6 章 可靠的数据传递 87. i$ y& {5 O: J3 A, e3 N
# u2 H, C) s) y' k
6.1 可靠性保证 87
# ~6 k2 `- g3 r9 X% |( m
( x0 E5 N9 L9 E% k/ Q/ F6.2 复制 88
6 t0 y8 K7 ^0 i* _* s& k1 C
' Y0 r% Q# ~' I& X# ]) W* ?6.3 broker配置 890 _' g( M1 U5 l! |1 {
- u; m: z5 m& r
6.3.1 复制系数 89
. n& \5 ?7 O& S. I# S% U+ W
! B* E* ~; F6 Y) z5 N6.3.2 不完全的首领选举 90
0 R: O- S1 S) Q6 y7 S% C _0 e8 {8 K# i4 l
6.3.3 少同步副本 91
: u2 G- u6 C" J/ [7 Y
/ P. N: }2 F7 D& v2 P% e' r8 [6.4 在可靠的系统里使用生产者 92
4 K5 S+ O) [ R" U3 H: y" ~5 \ O7 X+ V" L; C
6.4.1 发送确认 92
% c& o& ]* v5 M" U$ p5 |! n8 B
9 ~! _' {$ r, F6.4.2 配置生产者的重试参数 932 y2 \* c9 `" E+ w
: M5 S( k; M' \6.4.3 额外的错误处理 94
- L- S2 ]# p! E- z- z8 N& T8 d7 g" X1 k
6.5 在可靠的系统里使用消费者 94
5 h/ s4 `9 d0 P9 G, D
8 |6 P2 x' T& `% d6.5.1 消费者的可靠性配置 95! T( j. o l3 q9 r/ J8 f6 l$ G
4 k0 U. D2 L. _
6.5.2 显式提交偏移量 95
5 Y7 y* M! P9 |2 @
j6 c- x7 m: y5 Z6 b( W) X6.6 验证系统可靠性 97
( X( H0 C- U; Q
$ l* q$ S$ C0 K1 O$ _: s) t8 [5 o' Y6.6.1 配置验证 989 c, P! i9 S( o1 {# z% F1 d+ E, Z
' ]/ Z5 P7 H% x7 l
6.6.2 应用程序验证 98
. K! D) x. z! F1 ?2 q" w: h# i# r1 m' ]8 m" ?$ z2 t1 w4 [2 e
6.6.3 在生产环境监控可靠性 99
( M x% R$ J2 n$ F6 G" p4 H3 B: h& Q* N1 M: J' g
6.7 总结 1004 B e2 h9 E- B" d; @! D
$ y6 Y0 N- D. g9 S第 7 章 构建数据管道 101
$ W7 W3 w) @! w+ I6 a$ ^8 P+ I4 R$ W/ \. W# P
7.1 构建数据管道时需要考虑的问题 102
- W9 \* P6 s1 R s& X; D5 y& e: g; Y
7.1.1 及时性 102
: ?/ Z1 s+ A4 `) a$ D
, w9 b+ J7 D9 P0 D% I) R1 B7.1.2 可靠性 1020 Y3 Q5 l% _0 {3 }
$ `5 M. S/ \! K" e; S6 s& u* W7.1.3 高吞吐量和动态吞吐量 103( J* y# z# C' r8 y& k) k
& o% X! H' ]6 e& t7 ~# r: ~
7.1.4 数据格式 103
2 Z! Y2 c' P* T \" O9 Z! q( |4 o( L( p* Z, U' R9 R
7.1.5 转换 104
d5 C1 f, k9 n1 F$ T
9 A- E' g5 J4 v d# R3 J- b) N+ ^7.1.6 安全性 104
1 h9 w1 Q/ c9 I2 R7 w
. D. c+ T) p8 S. L F- J6 q" M/ e: P7.1.7 故障处理能力 104
3 X7 C. j1 ]* n# W) b0 r
0 t7 G6 x+ R+ x( U( F/ {" c7.1.8 耦合性和灵活性 105
5 L8 j- T- A8 h. {6 D7 ^% e+ k0 `
# T* Y3 F% C+ q& S3 j2 V6 ]; G3 U7.2 如何在Connect API和客户端API之间作出选择 105' f; q* Q8 O4 Y o3 H$ }3 P
5 k8 Z5 a1 A8 V0 v0 e" h. A
7.3 Kafka Connect 1068 x x0 F6 _ K8 _; K. U
1 x ~7 ^6 M! }1 s+ K- C7.3.1 运行Connect 106
; O0 ?- q- A9 l! C" ]6 ]* r6 L9 E: C* C8 o3 O- L, z9 E
7.3.2 连接器示例——文件数据源和文件数据池 1076 A1 D+ i5 n% q. _9 Z, D9 k
: p2 x) I3 ?1 r8 [
7.3.3 连接器示例——从MySQL到ElasticSearch 109- P! N4 |- F4 |# z2 c4 _
! c |. {& E) q$ i' h7.3.4 深入理解Connect 114
; J" Q7 L6 H% m H, g* ]# C/ {7 D* K7 w, ]$ H/ G
7.4 Connect之外的选择 116" O) X+ [* @% P, H
9 U s; Z1 z: Q9 Y( J1 g2 `! o7.4.1 用于其他数据存储的摄入框架 116
! j s- R1 a: {+ l, O: g$ y. v0 _* I2 N: i T q* E
7.4.2 基于图形界面的ETL工具 1171 r; Q8 b; C3 G B% T9 y7 M
( d5 J+ x% a# A! G8 v7.4.3 流式处理框架 1174 b i# S: r9 R0 }+ _
9 }2 ]1 ]# k1 l4 C; i1 Q' p7.5 总结 117
+ ^9 [1 e0 G4 V, y. ]3 T( F, i
g, [8 a4 E9 [3 W第 8 章 跨集群数据镜像 1181 b# y* O- t) L1 n- ]) N
; q- M" O7 Q2 _) z. S) }! I' L8.1 跨集群镜像的使用场景 118
# B3 z& f: V; O" @6 Y$ M ~
4 G, B: v* K7 B& V% S8.2 多集群架构 119
" F, R& x4 Q' I/ E$ y9 I/ U$ a5 W5 j
8.2.1 跨数据中心通信的一些现实情况 119
3 U* D! n' x0 _' |* O
+ _/ o' r. @- d/ E8 C8.2.2 Hub和Spoke架构 120
! v: j) Q4 Q+ B/ H$ @7 X
2 d9 V8 D: n) ]8.2.3 双活架构 121
1 z0 e r9 T+ q5 W/ j) e2 j: H+ d4 Z4 p
8.2.4 主备架构 123
% g; f: d1 Q, }* X) ]
4 ?# J% d2 c; \: {+ Q8.2.5 延展集群 127
" v* k+ a b& h- ?* u& z( O- _2 O( S! F
8 H4 A; Q# G& g+ T; r2 Y8.3 Kafka的MirrorMaker 128
/ b% p1 y) [4 p/ T: g# k
0 o+ a' C- x* q% G4 W8.3.1 如何配置 129( x7 e7 _1 p1 O" q/ m
; j+ i* j, v- z4 @) J7 z9 W- V; x
8.3.2 在生产环境部署MirrorMaker 1300 N/ Y3 ~% w: R+ Y
4 N; V! Y) I& @! l) O; f" K
8.3.3 MirrorMaker调优 132! O8 ~8 ?- W: S. D) J, E
8 I! S0 H" e" M; T. e0 p- w7 X9 X8.4 其他跨集群镜像方案 134
+ ~: _1 e2 L3 h5 [% b, Y/ w6 y! c9 T% r+ z- G. Y* {2 D
8.4.1 优步的uReplicator 134" m" a+ {: g4 `$ p9 E
* k1 x: W) \! w% F. K8.4.2 Confluent的Replicator 135
5 [2 E* `* j" u. ?+ |* X1 Z5 _* K& d
8.5 总结 135
$ [$ O, B% u$ b! m5 W
$ @; |: c( f$ V# [0 p* e8 C第 9 章 管理Kafka 136
8 d" W+ o" I7 A! m7 z. Z. R- [0 T8 \; A+ ~! H0 @
9.1 主题操作 136' X# R0 O/ P+ B {! v
# Z% a) `0 r4 Q, d+ P \
9.1.1 创建主题 137
% a0 U5 p1 z0 a
/ y+ f4 w$ G8 y/ ]9.1.2 增加分区 138) Y0 q. H3 m+ k1 w! E
7 q; m8 o3 P6 g1 M! h0 T& i. n$ \' \0 m1 U6 y9.1.3 删除主题 138( r% e4 b6 q/ }& L5 E4 x$ W& j4 ~% r5 X
6 m; W+ }3 b, J/ {* o' `# H
9.1.4 列出集群里的所有主题 139& c& {6 ~0 s( b6 K! C. b1 o
$ p$ T# q1 M6 S7 Q( _8 g
9.1.5 列出主题详细信息 139
, ^) N0 v# u$ L' o9 `- P- P# A* {) e
Z1 _& s8 I) v s6 h8 r. r1 r9 ]9.2 消费者群组 1402 W {; X% g& y$ y$ P& c" ^
6 G0 n8 }8 M/ v( P( u/ P4 R
9.2.1 列出并描述群组 1407 p% u; H* _+ v4 I) u8 D
. r4 ~) U4 k4 H1 \5 g, x
9.2.2 删除群组 142
A/ f) {2 r8 a1 _. T' I
+ v. O6 ~$ O7 l a9.2.3 偏移量管理 142) W4 U, u% i; S; |
: D: l+ ^. P6 U! R% c$ U
9.3 动态配置变更 143
7 j) k3 Z9 |9 Y# p _& q& H
, W; W# Q: }# C$ t+ O9.3.1 覆盖主题的默认配置 143
% `8 `# i, p m
( ]; W! y$ t9 b6 K9.3.2 覆盖客户端的默认配置 145
: G# m' s1 A8 A( c D$ C( e/ |8 J' ^4 A% e. e
9.3.3 列出被覆盖的配置 145: w' K- @0 j( M" f+ Z( t* r% Z
% L. D& C7 H1 {% j
9.3.4 移除被覆盖的配置 1460 o! Q9 ]9 p3 g: Y. u8 s2 w3 y2 J
" @% i: r" X/ {- o* [; D# {5 u' |& Q; L9.4 分区管理 146
% ?$ a1 H) {2 s
+ u w- S, a; o# Y9.4.1 的首领选举 1468 b( L" r& E$ I J! B- M
( z# h( z- a5 }- N9.4.2 修改分区副本 147, C- \, w! w+ Y" m/ s- f) ]5 u
5 s9 H2 z" c2 H, H6 G
9.4.3 修改复制系数 1502 X/ @( W+ H* H U
* J: z- }7 p2 j& ^' N2 ~9.4.4 转储日志片段 151
% e+ G, |. j( U2 r) j/ s! l
; k: K. K7 y8 [5 Y9.4.5 副本验证 152
- i7 T3 A! z) h Y9 N
0 y- G6 q0 u# L8 Z h; v1 O1 d! _+ k# W9.5 消费和生产 1533 {2 r5 ^$ u# \; P
0 p! F. B' i7 ?$ B, ?0 L$ o6 l `
9.5.1 控制台消费者 153" v; v9 I: q* l2 ]( s G
f @$ E& K0 u* g2 V7 C/ [. ?- @
9.5.2 控制台生产者 155
! M- W/ j- O& s" b' }
+ P+ L% c/ c& [) p9.6 客户端ACL 157" J9 b: I) c& B( X+ p' i/ `
- i. |; U9 N7 @) z9.7 不安全的操作 1576 ` K! ^* G: Y& g
8 Q4 R% W8 w$ z4 Z9.7.1 移动集群控制器 157
! g! T7 S& x- S" B5 ^/ t
/ V4 f7 c* T3 R* n* x9.7.2 取消分区重分配 157( `8 R F; n# N7 \+ g2 J
. v0 [# n4 A! E6 f4 i5 S" c/ I
9.7.3 移除待删除的主题 158" l5 ]+ ~; f# l$ Q% u
- D8 k) I$ Q& N; Y9.7.4 手动删除主题 158
8 A# y8 `! N3 I$ _/ `+ c9 Q# G
' C+ o5 X# o' \0 x7 k P9.8 总结 159
2 t" ^0 c$ V7 `* k& C/ f# t
) L: c8 @# ?6 d8 E第 10 章 监控Kafka 160& h6 P- ^( ^( `
8 Q% M- C( c& \
10.1 度量指标基础 160+ P4 J5 }9 p" K" d3 P3 ?
, E5 y, p Q9 `5 ^' m( w
10.1.1 度量指标在哪里 160% p' Z% F# y( f0 r. ^' d5 D0 P
* ^3 A% Y. Y" [# p10.1.2 内部或外部度量 161
0 w/ v5 V2 M0 } P
: ?" ~- E9 b$ Q% _+ U10.1.3 应用程序健康检测 161! c# d; z. q0 [+ \0 ], m; x: P
& i7 K {5 I* s6 w4 ?- E- U9 l
10.1.4 度量指标的覆盖面 161$ g5 o" y! N) T1 d) N; Z5 E
" `8 J5 j1 W6 a! f0 m- A' T10.2 broker的度量指标 162% S2 Q5 m6 @8 U+ E! T: O; v
# B. |5 n8 H4 e. M10.2.1 非同步分区 162* ^) L% r% S4 Z9 k* z8 h) W+ i7 k
/ m/ l- Y6 a- V. W' }9 d, v10.2.2 broker度量指标 166
; j) c9 K4 |/ P5 {* c) S/ G( Y, l- s( R
10.2.3 主题和分区的度量指标 173
! d! V6 b7 A7 b. h' Z: P7 ~' `8 i8 R9 l% E0 ~0 J) S; }
10.2.4 Java虚拟机监控 174
+ F. f0 I, Z6 w: E$ p: N8 F4 x- d' Z
10.2.5 操作系统监控 175
6 p9 i- T' a2 L
0 n0 p7 o, f/ n- n7 e6 P2 V10.2.6 日志 176" k9 v/ T$ z1 Q- v
& r6 C- f! Q! w n" t10.3 客户端监控 1778 Z% |1 d, N5 K- c! ^
& {5 R: m; ]+ N* x) D6 y+ ^
10.3.1 生产者度量指标 177
: T7 B1 E& H* e, }" V9 B f- o7 p
10.3.2 消费者度量指标 1796 _* Y+ q1 P0 |5 y
5 u X& {6 Q! Z! a# I
10.3.3 配额 181* a/ f% ]7 n e! b4 o
6 A/ g0 V4 `& o0 }6 q7 z
10.4 延时监控 1820 u1 r; ]( h7 S( ~
6 t6 q: s8 K$ b7 o/ W$ \0 x' N# L% ?5 a3 D
10.5 端到端监控 183" Q) W r* z3 l$ Z8 B3 C2 {
6 U( ]) ^9 c8 n, \, {7 ]/ o8 ^10.6 总结 1834 F8 r: v* ]- k# @
6 T9 I: C3 K' f( l* l
第 11 章 流式处理 1840 d- l7 x4 g- f, G
4 G: f4 s. _7 b
11.1 什么是流式处理 1850 P/ Q- q1 B0 C& X6 i
+ ^, f5 j; x$ r1 J
11.2 流式处理的一些概念 186
9 J5 f4 c4 ?8 ^( n* _
6 |8 F3 N5 d: ~9 s3 h5 q% K) |11.2.1 时间 187" {" |, B' C% t! {/ k) {
$ z; C) J( D) O& V, D11.2.2 状态 188; J9 O5 y. } }
, z ^3 |- M5 A0 \: x: q: ]
11.2.3 流和表的二元性 188% |% G3 f0 M8 N. T; H) r
" |% E0 C0 I9 {. j+ L, u11.2.4 时间窗口 189% u% y$ e) t2 N% q( R- K
1 O9 R4 ^0 L6 G ^3 k11.3 流式处理的设计模式 190, @: d* K: H" ~
4 j1 H7 U( `/ w+ e11.3.1 单个事件处理 191& X' i1 e0 N2 e' z6 v" X7 k E- x1 O
M, Y# s' k* P e5 t6 a2 d/ I
11.3.2 使用本地状态 191" Y( d* W( R, G% M
& v$ Y% U. c# p: D) Z8 c11.3.3 多阶段处理和重分区 193( x7 l5 {4 ?0 m* ]9 f. y
& B% U4 L# y7 x5 t& F9 v6 t% b3 x11.3.4 使用外部查找——流和表的连接 193( t1 C7 n6 Y- Y V4 u0 X
) X3 j5 }* t) P1 ]' `; M2 h
11.3.5 流与流的连接 195
1 J/ g; }( D. t6 r9 ]2 K+ y1 ]- U A2 C
11.3.6 乱序的事件 1951 u& {+ ?" w& M) l9 n( m( b5 N5 F- c% v
R7 A5 u7 J7 Z% K7 A* {11.3.7 重新处理 196
0 C5 c+ @" }, H0 x- @, L# o1 T) ]8 O9 h( `* F4 T0 ~* G
11.4 Streams示例 197+ n$ ]' c- q# k# ?1 E
3 A' ], g* G0 ?, z' M
11.4.1 字数统计 197* ?+ Q6 Q+ ]% ^& f
& F& b0 b# ]( H9 r11.4.2 股票市场统计 199
% I4 V* L& } W* p E2 Q$ w6 T8 F2 O7 l* T3 X; x3 m
11.4.3 填充点击事件流 201
3 m- p+ h, z/ x
* M4 B) C& s0 c5 R$ G& z11.5 Kafka Streams的架构概览 2028 N- l1 ~' Y/ C3 c
, R, q. E/ K8 x/ n7 v# q; d2 }$ a8 V+ y
11.5.1 构建拓扑 2026 V5 M5 w3 m s" R: ^5 W- b
java8.com
- o; u5 h/ E3 r6 {11.5.2 对拓扑进行伸缩 203) L4 x* b6 X7 ^8 }
$ m; B$ \$ ^. A4 Q
11.5.3 从故障中存活下来 205
( m) {2 G. B3 `9 a$ y
: y. f4 k' [3 [11.6 流式处理使用场景 205/ Y& U7 z; V% k
! J2 k' L8 C8 D, x% m C. B, b
11.7 如何选择流式处理框架 206
2 V) u% `$ A$ G2 X
: F+ P. M2 ?: a" v! t4 w0 |: z11.8 总结 208
* r& @" O. V, T) R# Y* l9 \
5 i- g, j5 T& ?6 i" x6 I' \) g- r$ K. t附录A 在其他操作系统上安装Kafka 209
m: k, y7 j5 Z' Q: g# G" S# O% V; O* }3 ?* B; ]( D. R
作者介绍 214# G) y7 h5 h7 c! R
, t9 {' N. a$ U! p9 E6 V4 |- w
封面介绍 214
1 I! z" }* q5 o3 }8 m3 {/ r百度云盘下载地址(完全免费-绝无套路)：1 \0 h& N: s6 C8 [ y
|
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
505 人阅读
|
17 人回复
|
2023-09-01
