KafKa发送原理
2023-06-18 10:01:59 12 举报KafKa发送原理
作者其他创作
大纲/内容
NetworkClient
InFlightRequests，默认每个broker节点最多缓存5个请求
Inerceptors拦截器
Kafka集群
分区1
分区2
Request 1
成功
发送
DQueue
Send(拉取数据)
Broker2
Partitioner分区器
Producer
达到batch.size或linger.ms
Broker1
外部数据
Kafka Producer 生产者
RecordAccumulator(默认32m)
Serializer序列化器
清理
Sender线程
分区3
Send(ProducerRecord)
重试
应答acks
main线程
ProducerBatch（默认16K）
Selector
Request 2
0 条评论
下一页
