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 条评论
回复 删除
下一页
