KafkaRequestHandler is a thread of execution (i.e. Java’s Runnable) that is responsible for relaying client requests (from RequestChannel) to KafkaApis (except
ShutdownRequest requests that are handled directly).
KafkaRequestHandler is created exclusively when
KafkaRequestHandlerPool is created (and starts the internal
Figure 1. KafkaRequestHandler’s Startup and Request Relay
KafkaRequestHandler uses [Kafka Request Handler [id] on Broker [brokerId]] as the logging prefix (aka
TRACE logging levels for
kafka.server.KafkaRequestHandler logger to see what happens inside.
Add the following line to
Starting Thread —
run is used when
KafkaRequestHandlerPool is created.
Creating KafkaRequestHandler Instance
KafkaRequestHandler takes the following when created: