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
logIdent is [Kafka Request Handler [id] on Broker [brokerId]].
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: