Page History

...

The following diagram displays the basic flow between the request managers, unsent request queue, and the NetworkClient: 

A request manager represents Request managers collect together the logic and stated needed to issue the different client a Kafka RPC requests and then handle their responses accordinglyhandle its response. A request manager may contain logic to handle more than one type of RPC.

In the network thread, we loop over each request manager, effectively asking it for any requests that it needs to send to the cluster. Note that during this step the network request is not sent. Instead, an unsent request object is created which contains the underlying request information. These "unsent requests" are added to a queue of pending unsent client requests. After all of these unsent requests are queued up, then they are forwarded for network I/O via the NetworkClient.send() method.

...