public class PendingOffsetForTimestamp
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancel the request
|
void |
completeExceptionally(org.apache.kafka.common.TopicPartition topicPartition,
java.lang.Exception exception)
Complete a TimestampAndOffset request exceptionally.
|
java.util.List<kafka.server.DelayedOperationKey> |
delayedOperationKeys()
Generate DelayedListOffsets purgatory operation keys
|
boolean |
isComplete() |
boolean |
isDone() |
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Optional<org.apache.kafka.common.record.FileRecords.FileTimestampAndOffset>> |
results() |
void |
run() |
java.util.Map<org.apache.kafka.common.TopicPartition,TierTimestampAndOffset> |
tierTimestampAndOffsets()
TierTimestampAndOffsets that will be resolved by this fetch
|
public boolean isDone()
public boolean isComplete()
public java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Optional<org.apache.kafka.common.record.FileRecords.FileTimestampAndOffset>> results()
public void completeExceptionally(org.apache.kafka.common.TopicPartition topicPartition, java.lang.Exception exception)
topicPartition
- the TopicPartition for the requestexception
- the exception to wrap in a FileTimestampAndOffsetpublic java.util.List<kafka.server.DelayedOperationKey> delayedOperationKeys()
public java.util.Map<org.apache.kafka.common.TopicPartition,TierTimestampAndOffset> tierTimestampAndOffsets()
public void run()
run
in interface java.lang.Runnable
public void cancel()