|
|
Java电子书：Apache Kafka源码剖析 格式 pdf 电子书 PDF 电子书 Java吧 java8.com% R" u4 v& [5 l7 g% N$ x! b
- |0 w% }1 t7 Q4 V9 c; G
$ X+ }+ I U+ o: o7 X& [1 e
编号：mudaima-P0305【Java吧 java8.com】9 z: O- Y( t9 |* b7 Y( o
! v1 l/ X% y$ @6 i: y1 s0 h( S& ]' X3 C
- s$ N0 w5 N5 X3 I+ C* O3 I5 c# ?
Java电子书目录：第1章 快速入门) E( d1 X' {5 r
1.1 Kafka简介! c# p: I* @2 L
1.2 以Kafka为中心的解决方案
0 b0 j; C" c3 V( A% m1.3 Kafka核心概念
1 ~6 f1 X" b8 G, F1.4 搭建Kafka源码环境
; p* `3 j/ C$ t: ^5 m本章小结$ v1 ^) q, ^% O% W( Y3 r" l4 P
; [" G, ]0 r7 [第2章 生产者7 o9 Q( ~/ H9 i& c
2.1 KafkaProducer使用示例7 G9 k% u( y" Z, s" T
2.2 KafkaProducer分析- I" C- h& w6 p+ g. s) x5 Z" K
2.2.1 ProducerInterceptors＆ProducerInterceptor
8 w5 Y% G- \7 n* Z# l3 h- x3 z2.2.2 Kafka集群元数据+ P! H5 T' p' S8 s( S! P+ e
2.2.3 Serializer＆Deserializer
2 W- Z( e/ S( \9 y& v$ Y$ z2.2.4 Partitioner
8 E" V) o8 J- C' V+ g& b3 y2.3 RecordAccumulator分析
0 W0 y' c$ Y! ], X2.3.1 MemoryRecords6 u0 ~/ Y% V0 @$ N5 M
2.3.2 RecordBatch
4 B" t9 p4 j0 J# S) }$ M8 P5 U X2.3.3 BufferPool
7 ~7 d* ]7 U+ A8 l2.3.4 RecordAccumulator
9 @" E5 g* x. J3 l4 V2.4 Sender分析" p% h: E1 j# `- S/ [- k* S$ [0 q& y
2.4.1 创建请求% Z* ]9 i$ u$ B: B7 T9 D3 I
2.4.2 KSelector
6 F( d* w0 K1 y3 a: U2.4.3 InFlightRequests' k0 D* M- J! B; c
2.4.4 MetadataUpdater$ x9 t/ \+ S, | h7 b, ^
2.4.5 NetworkClient
8 Y/ H# S, Q q' ` P本章小结- I; R. d7 k! D$ l
# U% i# T/ D; \; J8 W. {3 n8 q
第3章 消费者' w+ B$ B# o8 [3 }8 f7 l/ C
3.1 KafkaConsumer使用示例0 i; @+ I4 `4 l6 f* l
3.2 传递保证语义（Delivery guarantee semantic）) w; ?3 W* A% n; ?+ B7 |' V' F- m+ P0 g k
3.3 Consumer Group Rebalance设计: ^+ k7 B# G' X3 s
3.4 KafkaConsumer分析
1 O' i( W* Z9 t7 Z% z! y* \* ?3.4.1 ConsumerNetworkClient
: n9 N! W/ T& t# Y, Y3.4.2 SubscriptionState$ L3 @" T* z- t- l9 @
3.4.3 ConsumerCoordinator* N) Y/ q, D$ D1 d
3.4.4 PartitionAssignor分析
2 J* q6 \& x4 ]& }, F& N r3.4.5 Heartbeat分析
( w9 z( d, \+ P5 `3.4.6 Rebalance实现
! [& z6 P& @/ m7 W }3.4.7 offset操作4 m# }& g0 d% O6 w% ]# u
3.4.8 Fetcher8 D7 a& t0 ?% _7 @ {% C: o! Q& g# w
3.4.9 KafkaConsumer分析总结" Y" p4 q" e4 ?
本章小结
4 O) q, j" k6 L6 m+ ~2 E9 X' e( k% t
: m, e- M* u" v2 I, k, x0 {9 h第4章 Kafka服务端
* P: K8 H! V4 b! O1 _3 |! e4.1 网络层
* N3 z2 K, ^. i$ T! V' i6 v4.1.1 Reactor模式( A4 o0 G4 U5 y( P
4.1.2 SocketServer9 K H2 |1 c. z/ H% w5 s
4.1.3 AbstractServerThread
$ r6 Y* s, i: k# R9 H2 Z) p4.1.4 Acceptor
2 d3 v6 q. D' ^4 {; n& E: _4.1.5 Processor9 }+ v, p% Z3 s2 [1 m3 |7 n
4.1.6 RequestChannel
' L: v% Z4 F+ P/ t6 s1 v2 A4.2 API层
7 |& c( G4 ?, o m4 L+ u, ^" t7 c4.2.1 KafkaRequestHandler8 }( Q+ N* J$ C$ R& O: F8 K
4.2.2 KafkaApis) c3 m9 q ^3 @+ a6 L$ C
4.3 日志存储3 c5 m) `$ d7 G: d2 {( S) l
4.3.1 基本概念
& e; S( M( v3 y' V4 S) K# H4.3.2 FileMessageSet) Q; B# m& e1 N1 O) b/ e2 |( \
4.3.3 ByteBufferMessageSet/ E. `) x0 s: b3 I+ v. f& J& h
4.3.4 OffsetIndex' { ~) l0 i8 M5 f% I0 R
4.3.5 LogSegment0 R- b7 ~$ @7 ~9 C
4.3.6 Log( Z0 l. Y- c* ~6 A
4.3.7 LogManager
) R7 f. @0 |" [9 B0 r* ~! ~4.4 DelayedOperationPurgatory组件2 ~/ L2 F0 b" ]4 U
4.4.1 TimingWheel
+ ^9 \! L% |5 N, m. O4.4.2 SystemTimer k2 K9 K. x& S8 r+ k9 I
4.4.3 DelayedOperation
7 ^: T' p3 u( ^( W: j4 k6 r* U4.4.4 DelayedOperationPurgatory# t7 D) L- b# i t4 H
4.4.5 DelayedProduce0 V7 N3 J% Z7 g/ q+ Z
4.4.6 DelayedFetch
2 ?1 O( v# ~" y4.5 副本机制
# ]6 C8 P# z, I! c* h' A4.5.1 副本* w1 N6 O" z) U, U* q7 g/ o
4.5.2 分区
: Z( O# P! I% n, [1 e k4.5.3 ReplicaManager; O2 b* ^' z( H' C( D3 K+ u6 ?
4.6 KafkaController
5 E! c1 K" E+ a k( p4.6.1 ControllerChannelManager
3 f( }: U" J' j$ w+ H/ A4.6.2 ControllerContext3 U* B2 y# X+ `' | W' `
4.6.3 ControllerBrokerRequestBatch
) D8 `5 r8 v5 n: z' N4.6.4 PartitionStateMachine1 ]; h' q7 E# o& A
4.6.5 PartitionLeaderSelector+ S6 X# z$ d+ A. V, Y6 `0 J; V
4.6.6 ReplicaStateMachine
: _/ p9 o6 ?; Z! n+ f4 q1 G6 D4.6.7 ZooKeeper Listener) R, ^, p- A9 U J$ ^! r: }8 i- Y
4.6.8 KafkaController初始化与故障转移
+ ? n4 ?- ^5 g4.6.9 处理ControlledShutdownRequest
: h3 Y% W" Y) \. d L3 p w4.7 GroupCoordinator
% W x. X3 j4 a# P6 g4.7.1 GroupMetadataManager
. c, j6 P' b& L/ k6 X$ i1 h) B/ j3 `4.7.2 GroupCoordinator分析
y/ D7 {, o0 y9 E! f( C4.8 身份认证与权限控制* O' y5 M- L$ g3 ^
4.8.1 配置SASL/PLAIN认证7 A5 L& {+ ^) @; y4 v+ M
4.8.2 身份认证: N u0 r+ f& s* r
4.8.3 权限控制
4 A4 `+ P' c$ ?" f4.9 Kafka监控
7 j+ c' x& ?3 `6 o# H) O4.9.1 JMX简介
/ H$ C* r; L9 j% V4 V6 d% k! m# I4.9.2 Metrics简介
/ n' ^# f2 d: l. C3 {- Y4.9.3 Kafka中的Metrics; T" l( l! m3 w2 d0 N* S
4.9.4 Kafka的监控功能! d; S2 r1 q0 W6 I, p
4.9.5 监控KSelector的指标, p3 Z" S Q. n( y' z1 z3 ~1 C
1 u' F9 l- s1 W' Q; N3 a/ d) q第5章 Kafka Tool% \ h. Y2 t1 `) Y$ H5 _
5.1 kafka-server-start脚本" _" H! U: ?( X( s. X
5.2 kafka-topics脚本9 ^. E$ K; v& K6 [6 j+ f
5.2.1 创建Topic% \, X2 [8 j" N2 f, _9 }* F9 u% `
5.2.2 修改Topic
& t p5 }1 s1 q9 J8 ~$ b% P0 `/ r+ o0 @9 f5.3 kafka-preferred-replica-election脚本
7 z( m5 {& X+ f3 u( ^5.4 kafka-reassign-partitions脚本/ ]5 t5 ~0 V% p/ `- U
5.5 kafka-console-producer脚本# X" `* c) k3 y# I5 p
5.6 kafka-console-consumer脚本
# y( g; \% v: Q; n5 @" M5.7 kafka-consumer-groups脚本0 S, ]6 E7 {" `# O, G& W/ o+ X
5.8 DumpLogSegments
/ k1 q ?0 `" J0 j' R) Z8 J$ _- |5.9 kafka-producer-perf-test脚本
9 d# e" u- R( D% e5.10 kafka-consumer-perf-test脚本
^& t6 \' A, f+ T4 Y* B5.11 kafka-mirror-maker脚本
0 e8 U$ R* N* `9 a本章小结
; l7 L0 A7 g/ x2 g5 R, j# ] N: J3 j( P" q
- j; @3 J4 u9 h" h
百度云盘下载地址(完全免费-绝无套路)：# y$ A* C, @- Z
|
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
1297 人阅读
|
16 人回复
|
2023-09-01
