Page History

class ConsumerRecord<K, V> {
  /** 
   * Get the leader epoch or empty if it is unknown. 
   */
  Optional<Integer> leaderEpoch();
}

class OffsetAndMetadata {
  /**
   * New constructor including optional leader epoch. Old constructors
   * will still be supported and will use Optional.empty() as the default
   * leader epoch.
   */
  OffsetAndMetadata(long offset, String metadata, Optional<Integer> leaderEpoch); 


  /** 
   * Get the leader epoch or empty if it of the previously consumed offset (if one is unknownknown).
   * Log truncation is detected if the first offset of the epoch for the committed
   * offset is larger than this epoch and begins at an earlier offset.
   */
  Optional<Integer> leaderEpochlastLeaderEpoch();
}