第36课：Kafka源码解读SocketServer下的Acceptor、Processor、Handler 1 socketServer下的NIO 2 Acceptor、Processor、Handler
/** * An NIO socket server. The threading model is * 1 Acceptor thread that handles new connections * Acceptor has N Processor threads that each have their own selector and read requests from sockets * M Handler threads that handle requests and produce responses back to the processor threads for writing. */
class SocketServer(val config: KafkaConfig, val metrics: Metrics, val time: Time) extends Logging
