95-10-160-启动-KafkaApis

Posted 2021-08-31 九师兄

1.视界

概述

业务处理服务：KafkaApis，所有请求的处理入口。依赖了socketServer,replicaManager,adminManager,groupCoordinator,transactionCoordinator,fetchManager,tokenManager.可以说这个类是整个集群的统一处理的地方。

入口方法

/**
  * 成用于对外对外提供服务的KafkaApis实例,并设置当前的broker的状态为运行状态
* start processing requests
* 创建KafkaApis,处理各种Reequest的工具类，针对各个接口会处理不同的业务
* */
dataPlaneRequestProcessor = new KafkaApis(socketServer.dataPlaneRequestChannel