Class OffsetAndTimestamp
- java.lang.Object
-
- org.apache.kafka.clients.consumer.OffsetAndTimestamp
-
public final class OffsetAndTimestamp extends Object
A container class for offset and timestamp.
-
-
Constructor Summary
Constructors Constructor Description OffsetAndTimestamp(long offset, long timestamp)
OffsetAndTimestamp(long offset, long timestamp, Optional<Integer> leaderEpoch)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
Optional<Integer>
leaderEpoch()
Get the leader epoch corresponding to the offset that was found (if one exists).long
offset()
long
timestamp()
String
toString()
-
-
-
Method Detail
-
timestamp
public long timestamp()
-
offset
public long offset()
-
leaderEpoch
public Optional<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
-
-