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