RequestCompletionHandler

RequestCompletionHandler is the contract to attach an action that is executed when a request is complete, i.e. the corresponding response has been received or there was a disconnection while handling the request.

package org.apache.kafka.clients;

public interface RequestCompletionHandler {
    public void onComplete(ClientResponse response);
}
Table 1. RequestCompletionHandler’s Known Implementations
Name Description

RequestFutureCompletionHandler

TxnRequestHandler

TransactionMarkerRequestCompletionHandler

results matching ""

    No results matching ""