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 a new processor.

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

results matching ""

    No results matching ""