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

Class OffsetsForLeaderEpochUtils

java.lang.Object

org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils

public final class OffsetsForLeaderEpochUtils
extends Object

Utility methods for preparing requests to the OffsetsForLeaderEpoch API and handling responses.

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochUtils.OffsetForEpochResult	handleResponse(Map<org.apache.kafka.common.TopicPartition,SubscriptionState.FetchPosition> requestData, org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse response)

Methods inherited from class java.lang.Object

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

Method Details

handleResponse

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