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

Class OffsetsForLeaderEpochClient

java.lang.Object

org.apache.kafka.clients.consumer.internals.AsyncClient<Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition>,org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest,org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse,org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils.OffsetForEpochResult>

org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochClient

public class OffsetsForLeaderEpochClient
extends AsyncClient<Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition>,org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest,org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse,org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils.OffsetForEpochResult>

Convenience class for making asynchronous requests to the OffsetsForLeaderEpoch API

Method Summary

Modifier and Type	Method	Description
protected org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils.OffsetForEpochResult	handleResponse(org.apache.kafka.common.Node node, Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition> requestData, org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse response)
protected org.apache.kafka.common.requests.AbstractRequest.Builder<org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest>	prepareRequest(org.apache.kafka.common.Node node, Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition> requestData)

Methods inherited from class org.apache.kafka.clients.consumer.internals.AsyncClient

logger, sendAsyncRequest

Methods inherited from class java.lang.Object

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

Method Details

prepareRequest

protected org.apache.kafka.common.requests.AbstractRequest.Builder<org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest> prepareRequest(org.apache.kafka.common.Node node,
 Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition> requestData)

Specified by:

prepareRequest in class AsyncClient<Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition>,org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest,org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse,org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils.OffsetForEpochResult>

handleResponse

protected org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils.OffsetForEpochResult handleResponse(org.apache.kafka.common.Node node,
 Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition> requestData,
 org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse response)

Specified by:

handleResponse in class AsyncClient<Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition>,org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest,org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse,org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils.OffsetForEpochResult>