Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancel the request
|
void |
completeExceptionally(org.apache.kafka.common.TopicPartition topicPartition,
Exception exception)
Complete a TimestampAndOffset request exceptionally.
|
List<kafka.server.DelayedOperationKey> |
delayedOperationKeys()
Generate DelayedListOffsets purgatory operation keys
|
boolean |
isComplete() |
boolean |
isDone() |
Map<org.apache.kafka.common.TopicPartition,Optional<kafka.common.FetchedTimestampAndOffset>> |
results() |
void |
run() |
Map<org.apache.kafka.common.TopicPartition,kafka.common.TierUnfetchedTimestampAndOffset> |
tierTimestampAndOffsets()
TierTimestampAndOffsets that will be resolved by this fetch
|
public boolean isDone()
public boolean isComplete()
public Map<org.apache.kafka.common.TopicPartition,Optional<kafka.common.FetchedTimestampAndOffset>> results()
public void completeExceptionally(org.apache.kafka.common.TopicPartition topicPartition, Exception exception)
topicPartition
- the TopicPartition for the requestexception
- the exception to wrap in a FileTimestampAndOffsetpublic List<kafka.server.DelayedOperationKey> delayedOperationKeys()
public Map<org.apache.kafka.common.TopicPartition,kafka.common.TierUnfetchedTimestampAndOffset> tierTimestampAndOffsets()
public void cancel()