消费者组详细消费流程
2023-07-03 22:29:15 3 举报消费者组详细消费流程
作者其他创作
大纲/内容
group
send
ConsumerNetworkClient
SendFetches发送消费者请求
处理数据
Consumer
TopicA-Partition2
TopicA-Partition1
Fetch.min.bytes：每批次最小抓取大小，默认1字节Fetch.max.wait.ms：一批数据最小未到超时时间，500msFetch.max.bytes：每批次最大抓取，50m
parseRecord(反序列化)
Interceptors(拦截器)
onSuccess
FetchedRecords从队列中抓取数据Max.poll.records一次拉取的数据返回消息的最大条数，默认500
completedFetches（queue）
Kafka Cluster
TopicA-Partition0
0 条评论
下一页
