Kafka生产者流程
2021-12-20 14:29:31 0 举报kafka生产者流程
作者其他创作
大纲/内容
取出消息
M2
retries
拦截器
放入缓冲区
M3
KafkaProducer
M1
runOnce
序列化Key，Value
KafkaRecord
KafkaBroker
Queue
KafkaConsumer
sendProduceRequest
每个分区对应不同的nodeId
更新元数据
Kafka Broker
send
转化
sendProduceRequests
Sender
Sender线程
sendProducerData
发送消息
分区器
打包成ProducerBatch
KafkaClient.poll
onSend
消息
收藏
收藏
0 条评论
下一页
