public abstract class AbstractOffsetWriter extends Object implements OffsetWriter
OffsetWriter
Constructor and Description |
---|
AbstractOffsetWriter() |
Modifier and Type | Method and Description |
---|---|
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. |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
write
public void write(Map<org.apache.kafka.common.TopicPartition,Long> offsets) throws IOException
OffsetWriter
offsets
to a configured location with the current time specified as the as of time.write
in interface OffsetWriter
offsets
- the offsets to persistIOException
- if there is an error persisting the offsets.Copyright © 2017 The Apache Software Foundation. All rights reserved.