AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
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
收藏
立即使用
KafkaProducer源码阅读
zero
职业：研究生
去主页
Collect
Get Started
快速阅读：一年轻松读完1000本书
Collect
Get Started
阅读的分类
Collect
Get Started
MiniRPC- 源码阅读
Collect
Get Started
源码阅读技巧
评论
0
条评论
下一页
Document
