Kafka SASL认证授权(五)ACL源码解析。
官网地址:https://kafka.apache.org/
一、ACL检查流程解析
一起看一下kafka server的启动与监听流程:
Kafka -> KafkaServer -> SocketServer、KafkaRequestHandler
其中KafkaServer做相关的初始化,包括SocketServer 与 handler pool。
SocketServer的start up流程
看一下acceptor
acceptor实际执行流程:监听网络事件,提交给processor处理
看一下processor,截取KafkaServer代码:这边的numIoThreads就是配置的具体处理线程数量。KafkaApis封装具体的各api的