KafkaProducer源码阅读
2022-05-08 22:18:45 4 举报ccc
作者其他创作
大纲/内容
YES
开始/结束
重试
KafkaThread这个线程无限循环，直到调用KafakaProducer.close
发送消息
new ProducerRecord
失败
new KafkaProducer
根据一定的条件从Accumulator中拉取数据
消息发送
kafkaClient.send()
topic
YES:消息再次保存，等待重试
send()发送消息实际上只是保存消息到内存中，等待合适的时机才会有线程来拉取数据
后台线程从accumulator中取得消息
[partition]
[key]
分区1
根据分区策略选择分区
value
NO
分区0
序列化器
分区器
RecordAccumulator
收藏
0 条评论
下一页
