Package com.linkedin.venice.offsets

package com.linkedin.venice.offsets
  • Class
    Description
    DeepCopyOffsetManager
    This class is used to systematically copy OffsetRecord instances rather than passing them as is.
    DeepCopyStorageMetadataService
    This class is used to systematically copy OffsetRecord instances rather than passing them as is.
    InMemoryOffsetManager
    In memory implementation of OffsetManager, should really only be used for tests
    InMemoryStorageMetadataService
    In memory implementation of StorageMetadataService, should really only be used for tests
    OffsetManager
    This class records the offset for every pair(topic,partition) this node is responsible for.
    OffsetRecord
    If OffsetRecord is initialized with a serializer that contains SchemaReader, old version of server codes will be able to deserialize OffsetRecord that is serialized with a newer protocol version, which can happen after rolling back a server release with new protocol version to an old server release with old protocol version.