public abstract class AbstractTopicPartitionHistory extends Object implements TopicPartitionHistory
Modifier and Type | Method and Description |
---|---|
long |
deadlineMs()
Retrieves the deadline after which the history item expires.
|
long |
epoch()
Retrieves the epoch of the history item.
|
org.apache.kafka.common.TopicPartition |
topicPartition()
Retrieves the topic partition associated with this history item.
|
long |
untilDeadline(TimeUnit unit)
Retrieves the remaining time duration until the history item expires with the given
TimeUnit . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
compareTo
public org.apache.kafka.common.TopicPartition topicPartition()
TopicPartitionHistory
topicPartition
in interface TopicPartitionHistory
public long epoch()
TopicPartitionHistory
epoch
in interface TopicPartitionHistory
public long deadlineMs()
TopicPartitionHistory
deadlineMs
in interface TopicPartitionHistory
TopicPartitionHistory.untilDeadline(java.util.concurrent.TimeUnit)
public long untilDeadline(TimeUnit unit)
TopicPartitionHistory
TimeUnit
.untilDeadline
in interface TopicPartitionHistory