|
|
Java电子书：Apache Kafka源码剖析 格式 pdf 电子书 PDF 电子书 Java吧 java8.com
+ y! V% J# z# m# E, M% `2 N/ s. A- y& E) \5 i# z
. G, q# W# `; @
编号：mudaima-P0305【Java吧 java8.com】4 H T- f& p" F2 I5 H
( h7 r: t* G" l" M2 ?. L0 U7 v5 T$ }% |5 p
; y8 T+ ^* M- L$ P5 K6 |Java电子书目录：第1章 快速入门
$ a# I. }. h8 }4 l* R1.1 Kafka简介8 U6 `& d# P4 _ M3 ?8 I
1.2 以Kafka为中心的解决方案
- P7 _4 x9 I6 @/ i1.3 Kafka核心概念
/ t% a, n9 v% b b! H1.4 搭建Kafka源码环境
' m& b0 R/ w( N ~本章小结: L$ @/ F; Q7 S8 U. Z
% e5 T9 ?" m, _: C+ O& W第2章 生产者8 T7 ~4 O U2 h
2.1 KafkaProducer使用示例
5 ], B* B( c9 R! P' w: w2.2 KafkaProducer分析; G; v3 ?) T) v9 ~2 ~! D
2.2.1 ProducerInterceptors＆ProducerInterceptor2 k/ s8 i. V( x K/ h( [. s
2.2.2 Kafka集群元数据$ r' H5 n! M, q, i* F# z
2.2.3 Serializer＆Deserializer
& U2 R6 K( o0 s" `& D2.2.4 Partitioner
1 T, E6 f1 }) b! ]2 b1 P, |; N2.3 RecordAccumulator分析6 [* q* u" i2 `
2.3.1 MemoryRecords
2 ?8 t; f; X% [; v7 T9 \2.3.2 RecordBatch
* }) N* L- O2 m4 y2.3.3 BufferPool' B7 `) Y4 q8 ^/ x; b3 ~! j a" s' ^
2.3.4 RecordAccumulator
4 I/ S' m7 [* u2.4 Sender分析# I" q" h& }; o) s0 e
2.4.1 创建请求
; C T$ [( Z1 _/ K; ?2.4.2 KSelector' _8 K* X* j7 h
2.4.3 InFlightRequests
9 ?0 z0 s% Y# v) D+ y. H1 [ A2.4.4 MetadataUpdater
& j8 j3 t! v5 I! u2.4.5 NetworkClient5 q4 L* I" j+ q! F# }* m
本章小结: N. S3 y L( N+ L( _
6 I( g, p4 x+ Q l) C4 h第3章 消费者
& k1 w5 x+ a7 {0 n% W9 W3.1 KafkaConsumer使用示例! ~' p2 [' x0 y3 g
3.2 传递保证语义（Delivery guarantee semantic）
* u- ?8 x/ c3 S6 ]1 z3.3 Consumer Group Rebalance设计
" ]/ O6 b+ T3 i3.4 KafkaConsumer分析& m0 O' Q3 W+ N$ c9 a, k, F7 W
3.4.1 ConsumerNetworkClient8 [5 W& d/ W2 y" D& Z7 H
3.4.2 SubscriptionState8 D$ v! I; O0 R( W6 ~
3.4.3 ConsumerCoordinator
( m3 R) O2 t; e8 i3 u# {3.4.4 PartitionAssignor分析
9 \$ c* b( V- L, J, C! }3.4.5 Heartbeat分析
1 k3 d2 d2 d/ @ G3.4.6 Rebalance实现
! O2 G/ ]$ Q4 j" E3 I2 ^3.4.7 offset操作
$ ]$ v$ E: m* x" I6 t& H3.4.8 Fetcher& q: ?- f8 C6 Z5 K2 q3 [
3.4.9 KafkaConsumer分析总结
% ?! ^* x# O& k& t2 @' i+ {, E本章小结" ^3 b7 r3 X9 S, r* j/ Q
) ^/ F& M' K- g3 B' |; C* ?! u第4章 Kafka服务端
9 \9 X$ C" @, R& S ~0 U4.1 网络层0 S" f6 L0 q- h: A2 U5 l
4.1.1 Reactor模式/ T' S& \8 F& ^' x2 W" m+ e
4.1.2 SocketServer
4 ~- T8 t8 x: y2 }5 B( F$ D4.1.3 AbstractServerThread
( A6 r: T& M9 |( v- ]) s. i4.1.4 Acceptor
8 l/ L, @1 g" ]* E- I* h$ l: Y4.1.5 Processor
F T4 A/ L" P6 T4.1.6 RequestChannel* a% b8 Y2 X6 p4 {4 @ w
4.2 API层, M) y" \( _/ o3 Z, i
4.2.1 KafkaRequestHandler
4 c. _" B9 d/ A6 t( U' I- g4.2.2 KafkaApis/ x' e/ M( a" J
4.3 日志存储( I- K1 l$ d8 f" |2 l" z" M) m
4.3.1 基本概念% R+ y; v, I- V' h, L% I
4.3.2 FileMessageSet
! A$ B' r+ `7 f( K2 C. d" K, n4.3.3 ByteBufferMessageSet
+ U" D3 \" t0 m+ O3 C m$ O4.3.4 OffsetIndex! V" F" |% h* c/ O; I: s9 J! S$ c
4.3.5 LogSegment! R8 C9 C* p n6 K1 Y5 N6 }# L' I
4.3.6 Log
. S6 f4 M& f1 X" T$ o; z4.3.7 LogManager
) {! b, u% H# _ a% M$ _+ a- u4.4 DelayedOperationPurgatory组件
5 V; C% _4 f, W2 e4 {7 ]( K* i" B4.4.1 TimingWheel& @. {4 X- l- N- _ {2 Q) N* s7 q
4.4.2 SystemTimer
5 A' ~) W$ \% f4 ~, D; \4.4.3 DelayedOperation
5 m+ n. W8 v+ o& o) v+ i4.4.4 DelayedOperationPurgatory9 z) ?1 P9 W3 W0 c7 {" }' O
4.4.5 DelayedProduce
) }) P% Y) D! b' Q4.4.6 DelayedFetch }- d' j- c, R' M1 _
4.5 副本机制
$ K5 I {4 }/ w+ e: `, K4.5.1 副本7 @4 I6 Z- ]* d2 R
4.5.2 分区+ ?# S& D( @! U) r
4.5.3 ReplicaManager
. N2 U8 F0 z: ~, H4.6 KafkaController
( A' v( X% t B, \- h+ Y# M% X4.6.1 ControllerChannelManager
6 ?; H4 B& o* C8 o3 i+ b; G7 Q* ~* v4.6.2 ControllerContext! m, a1 q+ H3 n: C1 u# m
4.6.3 ControllerBrokerRequestBatch' _+ {7 r$ w4 N u' M
4.6.4 PartitionStateMachine7 s8 W6 R0 c G) L* Q3 m2 Z/ e' {
4.6.5 PartitionLeaderSelector( F% e; [8 A7 l6 H3 P
4.6.6 ReplicaStateMachine
g" Q( k( Q% I* N3 ]4.6.7 ZooKeeper Listener" E( W) D: M g7 F* N+ m% S
4.6.8 KafkaController初始化与故障转移' z- q# H6 H' s- h5 E
4.6.9 处理ControlledShutdownRequest
! g# h$ j! A9 P- M# p4 M" _4.7 GroupCoordinator9 F; ^( }: l. {6 ]6 ?
4.7.1 GroupMetadataManager& H( j0 b( U; H0 i
4.7.2 GroupCoordinator分析+ V; b8 J3 P/ G! z t
4.8 身份认证与权限控制/ c0 ^: d ^4 F5 D) z; \. G8 B# I
4.8.1 配置SASL/PLAIN认证
8 U9 E) g( Y7 ~/ h% Y/ b$ F# j0 g4.8.2 身份认证
( I$ w: ^6 j8 w7 a5 J4.8.3 权限控制
6 B* v6 X. l* C+ U' V- R* ^4.9 Kafka监控 i& R+ F; n* o. ?9 ^5 F3 S# B8 b
4.9.1 JMX简介
9 O+ m0 @ y3 a4 _; b( i4.9.2 Metrics简介
* N" A$ _( q Q1 c4.9.3 Kafka中的Metrics
: B( U$ [5 w: l8 h" ?4.9.4 Kafka的监控功能
" W/ Z# Z- c2 F; v; m$ ?9 E4 P) F' H4.9.5 监控KSelector的指标7 h9 o4 F. m, ]
) K, \" g" ?' o8 U3 i第5章 Kafka Tool$ c' m8 l$ A' S& N( `& b }* h1 H# v
5.1 kafka-server-start脚本# g" i0 O% d! i6 }! x8 y: U& _
5.2 kafka-topics脚本* y. I# u9 a3 ?: n$ B% `- c
5.2.1 创建Topic
2 Q7 \; B3 J4 g, i) |0 f* Q* Z( Y5.2.2 修改Topic
5 f! n9 m2 U* W6 Z7 q1 e7 ~8 u. f5.3 kafka-preferred-replica-election脚本
# c+ U( `* n8 t5 ^5.4 kafka-reassign-partitions脚本+ r' v, n ?( E
5.5 kafka-console-producer脚本/ A0 L% l8 q/ K9 }* f
5.6 kafka-console-consumer脚本! Z! {$ L5 a9 `& ?3 ] ^( l) q
5.7 kafka-consumer-groups脚本
C. K; I: ~2 V" O3 K! {8 F5.8 DumpLogSegments Z! |4 c4 m( \, t2 z0 ^
5.9 kafka-producer-perf-test脚本2 F. x- R* F6 h( j5 J. H
5.10 kafka-consumer-perf-test脚本
2 a& O" B: Z( d( N) f; y5.11 kafka-mirror-maker脚本
8 ~3 e: y9 U- t' K: c本章小结 4 K# K6 T3 r0 s6 B
4 p6 t+ \- h' E5 D* h* a7 Q" ~& b+ a
! \4 q& m6 H( }百度云盘下载地址(完全免费-绝无套路)：
; B) p- C! Z: M$ e& t7 v |
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
1171 人阅读
|
16 人回复
|
2023-09-01
