public class TierStateFetcher
extends java.lang.Object
Constructor and Description |
---|
TierStateFetcher(java.lang.Integer numThreads,
TierObjectStore tierObjectStore) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.util.concurrent.CompletableFuture<scala.collection.immutable.List<kafka.server.epoch.EpochEntry>> |
fetchLeaderEpochState(TierObjectStore.ObjectMetadata metadata)
Send a request to the tier state fetcher executor, returning a future that will be
completed when the request has read the tier state from the object store.
|
java.util.concurrent.CompletableFuture<java.nio.ByteBuffer> |
fetchProducerStateSnapshot(TierObjectStore.ObjectMetadata metadata) |
public TierStateFetcher(java.lang.Integer numThreads, TierObjectStore tierObjectStore)
public void close()
public java.util.concurrent.CompletableFuture<scala.collection.immutable.List<kafka.server.epoch.EpochEntry>> fetchLeaderEpochState(TierObjectStore.ObjectMetadata metadata)
metadata
- the tier object metadata for this tier state.public java.util.concurrent.CompletableFuture<java.nio.ByteBuffer> fetchProducerStateSnapshot(TierObjectStore.ObjectMetadata metadata)