Package org.apache.kafka.clients.consumer.internals

Class AsyncClient<T1,Req extends org.apache.kafka.common.requests.AbstractRequest,Resp extends org.apache.kafka.common.requests.AbstractResponse,T2>

java.lang.Object

org.apache.kafka.clients.consumer.internals.AsyncClient<T1,Req,Resp,T2>

Direct Known Subclasses:

OffsetsForLeaderEpochClient

public abstract class AsyncClient<T1,Req extends org.apache.kafka.common.requests.AbstractRequest,Resp extends org.apache.kafka.common.requests.AbstractResponse,T2>
extends Object

Method Summary

Modifier and Type	Method	Description
protected abstract T2	handleResponse(org.apache.kafka.common.Node node, T1 requestData, Resp response)
protected org.slf4j.Logger	logger()
protected abstract org.apache.kafka.common.requests.AbstractRequest.Builder<Req>	prepareRequest(org.apache.kafka.common.Node node, T1 requestData)
RequestFuture<T2>	sendAsyncRequest(org.apache.kafka.common.Node node, T1 requestData)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

sendAsyncRequest

public RequestFuture<T2> sendAsyncRequest(org.apache.kafka.common.Node node,
 T1 requestData)

logger

protected org.slf4j.Logger logger()

prepareRequest

protected abstract org.apache.kafka.common.requests.AbstractRequest.Builder<Req> prepareRequest(org.apache.kafka.common.Node node,
 T1 requestData)

handleResponse

protected abstract T2 handleResponse(org.apache.kafka.common.Node node,
 T1 requestData,
 Resp response)