Package org.apache.kafka.clients.consumer

Class OffsetAndTimestamp

java.lang.Object
org.apache.kafka.clients.consumer.OffsetAndTimestamp
public final class OffsetAndTimestampextends Object
A container class for offset and timestamp.

  • Constructor Details

    • OffsetAndTimestamp

      public OffsetAndTimestamp(long offset, long timestamp)

    • OffsetAndTimestamp

      public OffsetAndTimestamp(long offset, long timestamp, Optional<Integer> leaderEpoch)

  • Method Details

    • 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

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object