|Modifier and Type||Method and Description|
void write(Map<org.apache.kafka.common.TopicPartition,Long> offsets) throws IOException
offsetsto a configured location with the current time specified as the as of time.
void write(long asOfTime, Map<org.apache.kafka.common.TopicPartition,Long> offsets) throws IOException
offsetsto a configured location with metadata of
asOfTimeindicating 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 persist
IllegalArgumentException- if the
asOfTimeis less than 0.
IOException- if there is an error persisting the offsets.
Copyright © 2017 The Apache Software Foundation. All rights reserved.