Kafka相关01
2021-07-18 21:51:01 3 举报Kafka 发送流程详剖析 qq群：713264987
作者其他创作
大纲/内容
ProducerBatch
内存区域ByteBuffer
缓存InFlightRequests
ProducerRecord
网络I/O侧
partition
head
数据结构映射成key=节点
tail
封装请求
缓冲区RecordAccumulator
Dqueue
Deque<Request>.size()>max.in.flight.requests.per.connection?负载严重，采取规避措施：压力较小，可以正常发送
管理方法
新写消息大小>batch.size?new ProderBatch(实际size):new ProducerBatch(batch.size)
缓存数据Deque<ProducerBatch>
BufferPool
RecordAccumulato:缓冲消息，方便Sender线程批量发送，减少网络资源开销，提升吞吐量
max.in.flight.requests.per.connection
KafkaProducer
0 条评论
下一页
