public interface OffsetWriter extends Closeable
Modifier and Type | Method and Description |
---|---|
void |
write(long asOfTime,
Map<org.apache.kafka.common.TopicPartition,Long> offsets)
Persists the
offsets to a configured location with metadata of asOfTime indicating
the time in milliseconds when the offsets were meaningful. |
void |
write(Map<org.apache.kafka.common.TopicPartition,Long> offsets)
Persists the
offsets to a configured location with the current time specified as the as of time. |
void write(Map<org.apache.kafka.common.TopicPartition,Long> offsets) throws IOException
offsets
to a configured location with the current time specified as the as of time.offsets
- the offsets to persistIllegalArgumentException
- if the offsets
are null
.IOException
- if there is an error persisting the offsets.void write(long asOfTime, Map<org.apache.kafka.common.TopicPartition,Long> offsets) throws IOException
offsets
to a configured location with metadata of asOfTime
indicating
the time in milliseconds when the offsets were meaningful.asOfTime
- the metadata describing when the offsets are accurate as of a time given in milliseconds
since epoch.offsets
- the offsets to persistIllegalArgumentException
- if the offsets
are null
or the asOfTime
is less than 0.IOException
- if there is an error persisting the offsets.Copyright © 2017 The Apache Software Foundation. All rights reserved.