kafka请求处理流程图

processor

类:SocketServer

client

类：RequestChancel

reponseQueue

LogFile

requestQueue

KafkaRequestHandler线程

Ractor经典模型Dispatcher

package:kafka.network

ArrayBlockingQueue

ConcurrentHashMap

添加到请求队列

package:kafka.server

   Acceptor 线程类： 接收和创建外部 TCP 连接的线程。                             每个 SocketServer 实例只会创建一个 Acceptor 线程。                             将接收到的 Request 传递给下游的 Processor 线程处理。   Processor 线程类：                            处理单个 TCP 连接上所有请求的线程。每个 SocketServer 实例默认创建若干个（num.network.threads）Processor 线程。                            负责将接收到的 Request 添加到 RequestChannel 的 Request 队列上，                            负责将 Response 返还给 Request 发送方。

请求写入

Acceptor线程

类:KafkaRequestHandler

Processor线程池

响应