kafka-clients-RequestCompletionHandler.adoc

RequestCompletionHandler Contract

RequestCompletionHandler is the contract of request completion handlers that are executed when a request is complete, i.e. the corresponding response has been received or there was a disconnection while handling the request.

Table 1. RequestCompletionHandler Contract

Method

Description

onComplete

void onComplete(ClientResponse response) Action to be executed when a request is complete Used when: ClientResponse is requested to onComplete (when NetworkClient is requested to poll) ConsumerNetworkClient is requested to checkDisconnects (when ConsumerNetworkClient is requested to poll) InterBrokerSendThread is requested to completeWithDisconnect (when InterBrokerSendThread is requested to doWork)

Table 2. RequestCompletionHandlers (Direct Implementations)

RequestCompletionHandler	Description
RequestFutureCompletionHandler
TransactionMarkerRequestCompletionHandler
TxnRequestHandler