-
开始
初始化配置信息
- Properties配置转Map<String, Object>
- Map<String, Object>配置转ConsumerConfig
- 初始化重负载均衡配置GroupRebalanceConfig对象
- enable.auto.commit自动提交配置初始化
- ConsumerInterceptor消费拦截器对象初始化
- Metrics相关监控指标对象创建
- keySerializer对象创建序列化KEY使用
- valueSerializer对象创建序列化VALUE使用
- 偏移量重置策略OffsetResetStrategy类型对象创建
- 订阅状态跟踪器SubscriptionState类型对象创建
- ClusterResourceListeners集群资源监听器
- ConsumerMetadata
消费者元数据对象初始化（后续IO发起的时候会拉取全量元数据）
根据配置初始化通道构建器ChannelBuilder
NetworkClient对象创建
再封装ConsumerNetworkClient网络客户端
初始化消费者分区管理器ConsumerPartitionAssignor
初始化消费者协调器ConsumerCoordinator
初始化消费者数据获取器Fetcher
结束
开始
Properties配置转Map<String, Object>
Map<String, Object>配置转ConsumerConfig
初始化重负载均衡配置GroupRebalanceConfig对象
enable.auto.commit自动提交配置初始化
ConsumerInterceptor消费拦截器对象初始化
Metrics相关监控指标对象创建
keySerializer对象创建序列化KEY使用
valueSerializer对象创建序列化VALUE使用
偏移量重置策略OffsetResetStrategy类型对象创建
订阅状态跟踪器SubscriptionState类型对象创建
ClusterResourceListeners集群资源监听器
ConsumerMetadata
消费者元数据对象初始化（后续IO发起的时候会拉取全量元数据）
根据配置初始化通道构建器ChannelBuilder
NetworkClient对象创建
再封装ConsumerNetworkClient网络客户端
初始化消费者分区管理器ConsumerPartitionAssignor
初始化消费者协调器ConsumerCoordinator
初始化消费者数据获取器Fetcher
结束
Kafka14, Kafka源码14