public class FetchOffsetCache
extends java.lang.Object
Constructor and Description |
---|
FetchOffsetCache(org.apache.kafka.common.utils.Time time,
int size,
int timeoutMs) |
Modifier and Type | Method and Description |
---|---|
void |
expireEntries() |
FetchOffsetMetadata |
get(java.util.UUID objectId,
long offset) |
double |
hitRatio() |
void |
put(java.util.UUID objectId,
long offset,
FetchOffsetMetadata fetchOffsetMetadata) |
void |
put(java.util.UUID objectId,
long offset,
int byteOffset,
java.util.OptionalInt batchSize) |
long |
size() |
public FetchOffsetCache(org.apache.kafka.common.utils.Time time, int size, int timeoutMs)
public void put(java.util.UUID objectId, long offset, int byteOffset, java.util.OptionalInt batchSize)
public void put(java.util.UUID objectId, long offset, FetchOffsetMetadata fetchOffsetMetadata)
public FetchOffsetMetadata get(java.util.UUID objectId, long offset)
public double hitRatio()
public void expireEntries()
public long size()