kafka-network-SocketServer-Processor.adoc

Network Processor Thread (Socket Server Request Processor)

Processor is a java.lang.Runnable (as a AbstractServerThread) that is executed as a separately-executing thread.

Processor is also a KafkaMetricsGroup that…​FIXME

Processor is created exclusively when SocketServer is requested to create one.

Table 1. Processor’s Internal Properties (e.g. Registries, Counters and Flags)

Name	Description
inflightResponses	Map[String, RequestChannel.Response] Used when…​FIXME
newConnections	ConcurrentLinkedQueue[SocketChannel] Used when…​FIXME
responseQueue	LinkedBlockingDeque[RequestChannel.Response] Used when…​FIXME
selector	Selector Used when…​FIXME

Creating Processor Instance

Processor takes the following to be created:

• ID

• Time

• maxRequestSize

• RequestChannel

• ConnectionQuotas

• connectionsMaxIdleMs

• failedAuthenticationDelayMs

• Listener Name

• SecurityProtocol

• KafkaConfig

• Metrics

• CredentialProvider

• MemoryPool

• LogContext

Processor initializes the internal registries and counters.

processCompletedReceives Internal Method

processCompletedReceives()

processCompletedReceives…​FIXME

Note	processCompletedReceives is used exclusively when Processor is requested to run.

run Method

run(): Unit

Note	run is part of the java.lang.Runnable to start itself as a separately-executing thread.

run…​FIXME

configureNewConnections Internal Method

configureNewConnections(): Unit

configureNewConnections…​FIXME

Note	configureNewConnections is used exclusively when Processor is requested to run.

createSelector Internal Method

createSelector(
  channelBuilder: ChannelBuilder): KSelector

createSelector…​FIXME

Note	createSelector is used when Processor is created (and creates the Selector).