io.confluent.kafka.schemaregistry.storage

Class OffsetCheckpointReadOnly

java.lang.Object

io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint

io.confluent.kafka.schemaregistry.storage.OffsetCheckpointReadOnly

All Implemented Interfaces:

Closeable, AutoCloseable

public class OffsetCheckpointReadOnly
extends OffsetCheckpoint

This class read a map of topic/partition=>offsets from a file. The format of the file is UTF-8 text containing the following:

   <version>
   <n>
   <topic_name_1> <partition_1> <offset_1>
   .
   .
   .
   <topic_name_n> <partition_n> <offset_n>
 

The first line contains a number designating the format version (currently 0), the get line contains a number giving the total number of offsets. Each successive line gives a topic/partition/offset triple separated by spaces.

Field Summary

Fields inherited from class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint

CHECKPOINT_FILE_NAME, file, LOCK_FILE_NAME

Constructor Summary

Constructors

Constructor and Description
OffsetCheckpointReadOnly(String checkpointDir, int version, String topic)

Method Summary

Modifier and Type	Method and Description
protected void	setUpLockFile(File baseDir)
void	write(Map<org.apache.kafka.common.TopicPartition,Long> offsets) Write the given offsets to the checkpoint file.

Methods inherited from class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint

baseDir, close, delete, read, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

OffsetCheckpointReadOnly

public OffsetCheckpointReadOnly(String checkpointDir,
                                int version,
                                String topic)
                         throws IOException

Throws:

IOException

Method Detail

setUpLockFile

protected void setUpLockFile(File baseDir)

Overrides:

setUpLockFile in class OffsetCheckpoint

write

public void write(Map<org.apache.kafka.common.TopicPartition,Long> offsets)

Description copied from class: OffsetCheckpoint

Write the given offsets to the checkpoint file. All offsets should be non-negative.

Overrides:

write in class OffsetCheckpoint