駕校網(wǎng)站建設(shè)關(guān)鍵詞北京網(wǎng)站優(yōu)化哪家好
Kafka SASL認(rèn)證授權(quán)(五)ACL源碼解析。
官網(wǎng)地址:https://kafka.apache.org/
一、ACL檢查流程解析
一起看一下kafka server的啟動(dòng)與監(jiān)聽(tīng)流程:
Kafka -> KafkaServer -> SocketServer、KafkaRequestHandler
其中KafkaServer做相關(guān)的初始化,包括SocketServer 與 handler pool。
SocketServer的start up流程
看一下acceptor
acceptor實(shí)際執(zhí)行流程:監(jiān)聽(tīng)網(wǎng)絡(luò)事件,提交給processor處理
看一下processor,截取KafkaServer代碼:這邊的numIoThreads就是配置的具體處理線程數(shù)量。KafkaApis封裝具體的各api的