public class PendingFetch
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancel the pending fetch.
|
java.util.List<kafka.server.DelayedOperationKey> |
delayedOperationKeys()
Generate DelayedFetch purgatory operation keys
|
java.util.Map<org.apache.kafka.common.TopicPartition,TierFetchResult> |
finish()
Block on a fetch request finishing (or canceling), returning either complete MemoryRecords
for the fetch, or empty records.
|
boolean |
isComplete()
Checks if the pending fetch has finished
|
void |
run() |
public java.util.List<kafka.server.DelayedOperationKey> delayedOperationKeys()
public boolean isComplete()
public void run()
run
in interface java.lang.Runnable
public java.util.Map<org.apache.kafka.common.TopicPartition,TierFetchResult> finish()
public void cancel()