public abstract class AbstractOffsetReader extends Object implements OffsetReader
OffsetReader
Constructor and Description |
---|
AbstractOffsetReader() |
Modifier and Type | Method and Description |
---|---|
List<Long> |
getStoredOffsetPersistenceTimes()
Returns the list of available persistence times offsets have been written to the underlying storage mechanism.
|
Map<org.apache.kafka.common.TopicPartition,Long> |
readOffsets(long persistedOffsetTime)
Reads the offsets for a given
persistedOffsetTime . |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
readLatestOffsets
public Map<org.apache.kafka.common.TopicPartition,Long> readOffsets(long persistedOffsetTime) throws IOException
OffsetReader
persistedOffsetTime
. Note that not all storage mechanisms support
complete historical offset information. Use the OffsetReader.getStoredOffsetPersistenceTimes()
to find valid values
to specify for persistedOffsetTime
.readOffsets
in interface OffsetReader
persistedOffsetTime
- the persistence time when offsets were written to the underlying storage system.persistedOffsetTime
. If no offsets were persisted
at that time or available to be retrieved then null
will be returned.IOException
- if there is an error reading from the underlying storage.public List<Long> getStoredOffsetPersistenceTimes() throws IOException
OffsetReader
getStoredOffsetPersistenceTimes
in interface OffsetReader
empty list
is returned.IOException
- if there is an error reading from the underlying storage.Copyright © 2017 The Apache Software Foundation. All rights reserved.