AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
Kafka客户端整体流程
2021-11-06 12:15:53
10
举报
分享方式
免费使用
kafka客户端流程梳理
消息队列
kafka
模版推荐
作者其他创作
大纲/内容
Request
应用逻辑层
主线程
网络客户端NetworkClient
InFlightRequest
RecordAccmulator主要用来缓存消息，以便Sender线程可以批量发送，进而减少网络传输的资源消耗以提升性能。可以通过buffer.memory配置，默认32MB。如果生产者发送消息的速度超过发送到服务器的速度，则会导致生产者空间不足，这个时候KafkaProducer的send()方法调用要么被阻塞，要么抛出异常，这个取决于参数【max.block.ms】的配置，默认60秒。
本地消息收集器RecordAccumulator
Sender
ProducerBatch
Kafka Cluster
网络IO层
结构转换
序列化器Serializer
创建Request
Response
Sender线程
提交Selector准备发送
ProducerBatchbatch.size : 16K
ProducerRecord
缓存
拦截器ProducerInterceptors
分区器Partitioner
分区1
node3
分区2
KafkaProducer生产者发送器
ndoe1
node2
Selector
分区3
收藏
立即使用
kafka 索引文件执行流程
收藏
立即使用
jvm-sandbox-repeater 实现以及思考
收藏
立即使用
Redis
收藏
立即使用
Kafka客户端整体流程
凯雄
职业：一砖一码
去主页
Collect
Get Started
客户端测速模块流程逻辑
Collect
Get Started
wifi客户端
Collect
Get Started
群聊客户端逻辑
Collect
Get Started
客户端调用时序图
评论
0
条评论
下一页
Document
