KafkaRequestHandlerPool — Pool of Daemon KafkaRequestHandler Threads

KafkaRequestHandlerPool is a pool of daemon kafka-request-handler threads that are started immediately when KafkaRequestHandlerPool is created.

KafkaRequestHandlerPool.png
Figure 1. KafkaRequestHandlerPool and KafkaRequestHandler Threads
Note
The number of kafka-request-handler threads is controlled by num.network.threads Kafka property and defaults to 3.

KafkaRequestHandlerPool is created exclusively when KafkaServer is started.

Table 1. KafkaRequestHandlerPool’s Internal Properties (e.g. Registries and Counters)
Name Description

aggregateIdleMeter

runnables

Collection of KafkaRequestHandler

KafkaRequestHandlerPool uses [Kafka Request Handler on Broker [brokerId]] as the logging prefix (aka logIdent).

shutdown Method

Caution
FIXME

Creating KafkaRequestHandlerPool Instance

KafkaRequestHandlerPool takes the following when created:

KafkaRequestHandlerPool initializes the internal registries and counters and starts numThreads daemon kafka-request-handler threads (as registered in runnables).

results matching ""

    No results matching ""