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

Class SubscriptionState.FetchPosition

java.lang.Object

org.apache.kafka.clients.consumer.internals.SubscriptionState.FetchPosition

Enclosing class:

SubscriptionState

public static class SubscriptionState.FetchPosition
extends Object

Represents the position of a partition subscription. This includes the offset and epoch from the last record in the batch from a FetchResponse. It also includes the leader epoch at the time the batch was consumed.

Field Summary

Fields

Modifier and Type	Field	Description
final long	offset

Constructor Summary

Constructors

Constructor	Description
FetchPosition(long offset, Optional<Integer> offsetEpoch, org.apache.kafka.clients.Metadata.LeaderAndEpoch currentLeader)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

offset

public final long offset

Constructor Details

FetchPosition

public FetchPosition(long offset,
 Optional<Integer> offsetEpoch,
 org.apache.kafka.clients.Metadata.LeaderAndEpoch currentLeader)

Method Details

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object