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).

results matching ""

    No results matching ""