public abstract class AbstractTierMetadata
extends java.lang.Object
Constructor and Description |
---|
AbstractTierMetadata() |
Modifier and Type | Method and Description |
---|---|
static java.util.Optional<AbstractTierMetadata> |
deserialize(byte[] key,
byte[] value)
Deserializes byte key and value read from Tier Topic into Tier Metadata.
|
abstract java.nio.ByteBuffer |
payloadBuffer() |
byte[] |
serializeKey() |
byte[] |
serializeValue() |
abstract int |
tierEpoch()
tierEpoch for the tier metadata
|
abstract org.apache.kafka.common.TopicPartition |
topicPartition()
Topic-partition corresponding to this tier metadata.
|
abstract byte |
type() |
public byte[] serializeKey()
public byte[] serializeValue()
public static java.util.Optional<AbstractTierMetadata> deserialize(byte[] key, byte[] value) throws TierMetadataDeserializationException
key
- Key containing archived topic partitionvalue
- Value containing tier metadata.TierMetadataDeserializationException
public abstract byte type()
public abstract org.apache.kafka.common.TopicPartition topicPartition()
public abstract int tierEpoch()
public abstract java.nio.ByteBuffer payloadBuffer()