Class OffsetAndTimestamp
- java.lang.Object
-
- org.apache.kafka.clients.consumer.OffsetAndTimestamp
-
public final class OffsetAndTimestamp extends java.lang.ObjectA container class for offset and timestamp.
-
-
Constructor Summary
Constructors Constructor Description OffsetAndTimestamp(long offset, long timestamp)OffsetAndTimestamp(long offset, long timestamp, java.util.Optional<java.lang.Integer> leaderEpoch)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(java.lang.Object o)inthashCode()java.util.Optional<java.lang.Integer>leaderEpoch()Get the leader epoch corresponding to the offset that was found (if one exists).longoffset()longtimestamp()java.lang.StringtoString()
-
-
-
Method Detail
-
timestamp
public long timestamp()
-
offset
public long offset()
-
leaderEpoch
public java.util.Optional<java.lang.Integer> leaderEpoch()
Get the leader epoch corresponding to the offset that was found (if one exists). This can be provided to seek() to ensure that the log hasn't been truncated prior to fetching.- Returns:
- The leader epoch or empty if it is not known
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equalsin classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
-