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 State Topic into Tier Metadata.
|
static java.util.Optional<AbstractTierMetadata> |
deserialize(java.nio.ByteBuffer key,
java.nio.ByteBuffer value) |
static TopicIdPartition |
deserializeKey(byte[] key) |
static TopicIdPartition |
deserializeKey(java.nio.ByteBuffer key) |
boolean |
equals(java.lang.Object o) |
static byte |
getTypeId(byte[] value)
Deserializes just the type from a value read from a Tier State Topic
|
int |
hashCode() |
abstract java.util.UUID |
messageId()
Get a unique id for this message.
|
java.lang.String |
messageIdAsBase64()
Encode messageId with Base64
|
abstract java.nio.ByteBuffer |
payloadBuffer() |
byte[] |
serializeKey() |
byte[] |
serializeValue() |
abstract int |
tierEpoch()
tierEpoch for the tier metadata
|
abstract TopicIdPartition |
topicIdPartition()
Topic-partition corresponding to this tier metadata.
|
abstract TierRecordType |
type() |
public byte[] serializeKey()
public byte[] serializeValue()
public static byte getTypeId(byte[] value)
value
- value bytespublic static TopicIdPartition deserializeKey(byte[] key)
public static TopicIdPartition deserializeKey(java.nio.ByteBuffer key)
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 static java.util.Optional<AbstractTierMetadata> deserialize(java.nio.ByteBuffer key, java.nio.ByteBuffer value) throws TierMetadataDeserializationException
public abstract TierRecordType type()
public abstract TopicIdPartition topicIdPartition()
public abstract java.nio.ByteBuffer payloadBuffer()
public abstract int tierEpoch()
public abstract java.util.UUID messageId()
public java.lang.String messageIdAsBase64()
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object