1. 程式人生 > >Kafka Broker處理請求流程

Kafka Broker處理請求流程

生產請求:生產者傳送的請求,包含客戶端要寫入分割槽首領broker的訊息。

獲取請求:消費者和跟隨著副本需要從分割槽首領broker讀取訊息時傳送的請求。

broker會在它監聽的每一個埠上執行一個Acceptor執行緒,這個執行緒會去建立一個連線,並把它交給Processor去處理。Processor執行緒的數量是可配置的。Processor執行緒獲取請求訊息,把請求訊息放入請求佇列,然後從響應佇列獲取響應訊息,把響應訊息返回給客戶端或其他broker。

請求訊息被放入請求佇列後,I/O執行緒會負責處理它們,並把處理結果發到響應佇列。