消费者组详细消费流程
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 条评论
回复 删除
下一页