Kafka生产消费原理图
2022-04-19 23:16:47 28 举报Kafka生产消费原理图
作者其他创作
大纲/内容
......
Response
ProducerBatch
node 1
broker
处理数据
主线程
TopicA-Partition0 (follower)
Request
parseRecord(反序列化)
node n
Group
提交给 Selector 准备发送
发送
缓存
InFlightRequests
Sender 线程
KafkaProducer
TopicA-Partition2 (Leader)
分区1
消息累加器 RecordAccumulator
broker0
创建 Request
Consumer
NetWorkClient
TopicA-Partition1(follower)
清理
拦截器ProducerInterceptors
ConsumerInteceptors(拦截器)
TopicA-Partition0 (Leader)
Pull 数据
Sender (读取数据)
completedFetches(queue)
序列化器Serializer
分区器partitioner
分区2
Kafka Clsuter
分区n
node 2
Selector
TopicA-Partition2 (follower)
TopicA-Partition1 (Leader)
应答 ACKS
0 条评论
下一页
