图2.15-记录收集器的时序图-当需要新建batch的时候
2022-04-10 12:17:52 0 举报
目前正在写kafka的书，整理了一下生产端记录收集器的工作原理时序图
作者其他创作
大纲/内容
②onNewBatch
RecordAccumulator
append
MemoryRecords
④recordsBuilder创建recordBuilder
Partitioner
MemoryRecords.builder
①tryAppend 触发abortOnNewBatch
ProducerBatch
tryAppend
BufferPool
getOrCreateDeque
tryAppend-deque中没有batch需要先分配buffer
③分配buffer
new ProducerBatch
KafkaProducer
tryAppend此时deque中还是没有batch
⑤append
0 条评论
回复 删除
下一页
