|
|
Java电子书：Apache Kafka源码剖析 格式 pdf 电子书 PDF 电子书 Java吧 java8.com
3 |( a( t3 ?2 i/ s( r& U
( `8 F; V' j7 q9 ]0 G8 l6 _/ m* m0 z4 X
编号：mudaima-P0305【Java吧 java8.com】 h+ o4 Z& p5 F' W
& [1 u4 g9 v a* @' \
9 ]0 B' M' @) @' a! N
1 V0 }2 `2 t) j" }Java电子书目录：第1章 快速入门$ F, P: ^% E: f) Y
1.1 Kafka简介
! `0 C+ G% e8 `) Z2 g! d# H. X1.2 以Kafka为中心的解决方案
+ x! k0 W* w. o& J7 ~' z/ n+ d1.3 Kafka核心概念5 d- \% V, D( v z/ h
1.4 搭建Kafka源码环境# K2 U/ K8 m+ V$ p0 p
本章小结4 V: ~& M r% ^& L# h' Z& d P
8 S) e0 N+ z# i
第2章 生产者/ C) c) c) S4 t
2.1 KafkaProducer使用示例
; z1 X( k6 T0 U9 A6 m2.2 KafkaProducer分析
" n( C6 Z8 x8 d% T& J9 \1 [2.2.1 ProducerInterceptors＆ProducerInterceptor
+ c K/ P/ O4 [3 P' ^+ z2.2.2 Kafka集群元数据9 U" q$ y9 u$ u: c0 J+ a
2.2.3 Serializer＆Deserializer
+ H T% b6 f! K% |2.2.4 Partitioner
" W' D- Z& y/ ]- C: e2.3 RecordAccumulator分析5 U# {+ m- A; p) ^# e+ Y
2.3.1 MemoryRecords
. T3 w, V: _$ q2.3.2 RecordBatch4 ^ c C& J8 g l( ^) b% f& f
2.3.3 BufferPool& H" r8 c- M2 d) n3 b, f& S
2.3.4 RecordAccumulator- N1 J J2 y. k( n' `! I( V1 N8 D: @
2.4 Sender分析2 p! S i* @: p
2.4.1 创建请求) k ]) `$ I( A4 M
2.4.2 KSelector, m5 k: j+ ]( E0 i' O% m
2.4.3 InFlightRequests) S$ f; q4 |+ Z6 x
2.4.4 MetadataUpdater4 }( j# M s2 B
2.4.5 NetworkClient
6 q+ x" B1 t* h2 R本章小结6 D4 W5 B W6 j/ O3 Y& H6 s6 `
w8 ^, U/ C+ f8 A9 Q( t第3章 消费者- P0 A* a+ s1 c2 y4 X% Q
3.1 KafkaConsumer使用示例- O# D5 z3 W$ k: k- l; q3 O- b7 ]
3.2 传递保证语义（Delivery guarantee semantic）
! N7 {/ V5 E- {: m# F X( M5 [+ [3.3 Consumer Group Rebalance设计7 C- c3 o' e/ B" M; t
3.4 KafkaConsumer分析
# [& R2 K; D4 i/ A; L3.4.1 ConsumerNetworkClient' d3 t8 Q' P) i; S
3.4.2 SubscriptionState
- A7 B+ g# O4 W; _; `0 j3.4.3 ConsumerCoordinator
) s+ t/ n# j* @$ {5 K: G! C3.4.4 PartitionAssignor分析' u* N* r8 m2 F
3.4.5 Heartbeat分析/ e( k; d2 T4 K7 r
3.4.6 Rebalance实现
: x* D1 O( T4 K% f* ^& A$ W1 i3.4.7 offset操作* X" z a. N( m
3.4.8 Fetcher
1 r! Y' a: _" Z: r; r, m' P3.4.9 KafkaConsumer分析总结/ `5 f4 p. u0 _+ S0 c) G( m( a
本章小结
) Z: i( a1 S' f2 i0 B3 y L8 R6 i, {% t( L( T0 z
第4章 Kafka服务端
6 i4 q+ T" k) s, h4.1 网络层+ F5 b. N V6 T4 q9 z- B* {6 C
4.1.1 Reactor模式& P, ? W/ f, a0 b/ {( J& M8 J
4.1.2 SocketServer j* Y1 ]" [, q6 b
4.1.3 AbstractServerThread
$ Z4 N) g+ {+ M4 n3 O" R4.1.4 Acceptor& d" F2 O2 s! q) @
4.1.5 Processor
7 x7 }) h( t+ t4.1.6 RequestChannel* e+ f7 @6 H+ ~4 ?6 ^$ z. C
4.2 API层# P1 K' Q& m! `* y; q
4.2.1 KafkaRequestHandler; o, Y; M! {9 q& k: J; J
4.2.2 KafkaApis
) v- ?: K5 W( ^7 M. X* K4.3 日志存储# Z# o. z6 F' ~. t6 C6 P; z
4.3.1 基本概念( D1 R1 g! M7 \& i9 ^7 Q
4.3.2 FileMessageSet
. g' @/ \+ W) E3 u5 l2 c9 d( F4.3.3 ByteBufferMessageSet
$ J7 B9 \% A$ b4.3.4 OffsetIndex& D- Q, h" Z( I( x/ ]* |3 F8 L1 P, w% Z
4.3.5 LogSegment
2 j! ^5 V" `. `4.3.6 Log+ d0 k4 M! o% O, g O5 z
4.3.7 LogManager
! r5 l: |! Y7 y8 {5 a. c& n8 J' [4.4 DelayedOperationPurgatory组件
6 s* u }/ Q8 }5 T& A! z, {4.4.1 TimingWheel
5 p x# j6 D0 z& X- H q" U4.4.2 SystemTimer
( w$ D9 j) J/ z7 _+ [4.4.3 DelayedOperation
$ Q8 `* M/ @/ [" e- i( v! q4.4.4 DelayedOperationPurgatory
6 _- k, C ~, m4.4.5 DelayedProduce
( d6 }5 u- w. l5 A' k+ ^! o4.4.6 DelayedFetch( q# j- L# P" {% Z( p
4.5 副本机制% |- N7 h* B2 I; N
4.5.1 副本/ D0 c) ~" D" `) f- ^, h1 [6 Q
4.5.2 分区' \/ ?2 `: [ j, w! I- J4 J
4.5.3 ReplicaManager
I/ t. v6 O4 p7 L! B8 _4.6 KafkaController/ C! s6 E: S: `9 A) ~
4.6.1 ControllerChannelManager' ~$ x5 H7 b1 [# c9 q0 [
4.6.2 ControllerContext \3 p$ g+ L$ g3 U4 v: h
4.6.3 ControllerBrokerRequestBatch; [: N/ | S( b; o9 ~, Z
4.6.4 PartitionStateMachine: N& S6 T% Z( {# V6 j4 q
4.6.5 PartitionLeaderSelector
8 @1 r) C2 p. s2 a4.6.6 ReplicaStateMachine' v) C |) k; B. V8 l- ^' Q
4.6.7 ZooKeeper Listener) l/ B# G% d2 ^) A# s8 L. |
4.6.8 KafkaController初始化与故障转移+ Q/ Q) h* I$ J
4.6.9 处理ControlledShutdownRequest; y4 @6 r7 ?: j
4.7 GroupCoordinator* R( d7 U: V: g5 s9 B
4.7.1 GroupMetadataManager
$ N3 O6 Y, U9 j2 I4.7.2 GroupCoordinator分析
e* ~ s' \$ Y# `4.8 身份认证与权限控制
1 u* z% F- n* M% \0 z2 t4.8.1 配置SASL/PLAIN认证
8 t5 H4 T- O( p2 ~3 L5 }4.8.2 身份认证
$ m* P+ C- Z" b" P1 ?4.8.3 权限控制
0 ?. L+ I1 u( E* b" ]; t/ ~. v. r- j4.9 Kafka监控3 x* k$ H! I7 ~7 i+ p
4.9.1 JMX简介
' J7 M/ m* c8 b$ o$ D4.9.2 Metrics简介
5 r" J. G' h, z- I7 A4.9.3 Kafka中的Metrics
; ]5 [* s3 A7 v" ?8 y$ F0 A" @4.9.4 Kafka的监控功能+ t, H. B/ s; S$ U1 V- F/ h
4.9.5 监控KSelector的指标
$ S! x/ T& R s! J# b
m, p( ]+ r4 t5 S第5章 Kafka Tool% ?' \3 V& A1 ^$ r, K/ e
5.1 kafka-server-start脚本& k# W0 m. o) |5 V1 r' q! ~
5.2 kafka-topics脚本; G. K5 g' a* b
5.2.1 创建Topic
# v. @, ]- D# |! Q4 g' M5.2.2 修改Topic
* w2 x9 a& Z9 T9 r/ Z5.3 kafka-preferred-replica-election脚本3 x) z5 Y9 W" K0 A8 ], F
5.4 kafka-reassign-partitions脚本
, m7 J+ X% | |! H6 L5.5 kafka-console-producer脚本2 ^; [' ^0 G; z6 V" V ~
5.6 kafka-console-consumer脚本
; E& g: P' b. z8 H* ^5.7 kafka-consumer-groups脚本
3 ?5 _5 Z/ I3 m; }1 {, J5.8 DumpLogSegments. V/ v: c# n t2 C
5.9 kafka-producer-perf-test脚本5 C: p5 Z) r: R5 a+ n0 O
5.10 kafka-consumer-perf-test脚本1 l& J+ ?8 H( s
5.11 kafka-mirror-maker脚本
3 P0 j0 Q/ k/ U% E; N# H9 ^* t本章小结 3 C- t$ G& _1 D+ f' W3 G. [/ E [
2 l5 e, b$ p6 W2 Q2 p8 D6 o* ^) `9 p
百度云盘下载地址(完全免费-绝无套路)：4 [3 G7 J4 W. n' L2 `
|
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
2078 人阅读
|
16 人回复
|
2023-09-01
