public class TierMetadataSnapshotUploadComplete extends AbstractTierMetadata
Modifier and Type | Field and Description |
---|---|
static byte |
CURRENT_VERSION |
static byte |
VERSION_V1 |
static byte |
VERSION_V2 |
static byte |
VERSION_V3 |
static byte |
VERSION_V4 |
Constructor and Description |
---|
TierMetadataSnapshotUploadComplete(TierMetadataSnapshotUploadInitiate snapshotInitiate,
FileTierPartitionStateSnapshotObject snapshotObject,
Optional<org.apache.kafka.raft.OffsetAndEpoch> partitionCreationOffsetAndEpoch) |
TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition,
int tierEpoch,
UUID objectId,
OffsetAndEpoch stateOffset,
OffsetAndEpoch snapshotOffset,
long snapshotTimestampMs,
byte checksumAlgorithm,
Optional<org.apache.kafka.raft.OffsetAndEpoch> partitionCreationOffsetAndEpoch)
Constructs a new instance of TierMetadataSnapshotUploadComplete.
|
TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition,
MetadataSnapshotUploadComplete metadata) |
Modifier and Type | Method and Description |
---|---|
Algorithm |
checksumAlgorithm() |
static int |
initialBufferSize()
The initial buffer size to use when constructing the FlatBuffer message.
|
UUID |
messageId()
Get a unique id for this message.
|
Optional<org.apache.kafka.raft.OffsetAndEpoch> |
partitionCreationOffsetAndEpoch() |
ByteBuffer |
payloadBuffer() |
OffsetAndEpoch |
snapshotOffsetAndEpoch() |
long |
snapshotTimestampMs() |
OffsetAndEpoch |
stateOffsetAndEpoch()
The lastMaterializedOffsetAndEpoch for the tier partition state at the time this metadata was generated.
|
int |
tierEpoch()
tierEpoch for the tier metadata
|
TopicIdPartition |
topicIdPartition()
Topic-partition corresponding to this tier metadata.
|
String |
toString() |
TierRecordType |
type() |
byte |
version() |
deserialize, deserialize, deserializeKey, deserializeKey, equals, getTypeId, hashCode, messageIdAsBase64, serializeKey, serializeValue, timestamp
public static final byte VERSION_V1
public static final byte VERSION_V2
public static final byte VERSION_V3
public static final byte VERSION_V4
public static final byte CURRENT_VERSION
public TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition, int tierEpoch, UUID objectId, OffsetAndEpoch stateOffset, OffsetAndEpoch snapshotOffset, long snapshotTimestampMs, byte checksumAlgorithm, Optional<org.apache.kafka.raft.OffsetAndEpoch> partitionCreationOffsetAndEpoch)
topicIdPartition
- topicIdPartition of the metadatatierEpoch
- tier epoch of partitionobjectId
- unique id to identify a FTPS snapshotstateOffset
- lastMaterializedOffsetAndEpoch when MetadataSnapshotUploadInitiate metadata event was generatedsnapshotOffset
- lastMaterializedOffsetAndEpoch when FTPS snapshot was taken, added in v3snapshotTimestampMs
- timestamp at which snapshot was takenchecksumAlgorithm
- checksum algorithm, added in v2partitionCreationOffsetAndEpoch
- Optional KRaft metadata offset and epoch when partition was created, added in v4, only present in KRaft modepublic TierMetadataSnapshotUploadComplete(TopicIdPartition topicIdPartition, MetadataSnapshotUploadComplete metadata)
public TierMetadataSnapshotUploadComplete(TierMetadataSnapshotUploadInitiate snapshotInitiate, FileTierPartitionStateSnapshotObject snapshotObject, Optional<org.apache.kafka.raft.OffsetAndEpoch> partitionCreationOffsetAndEpoch)
public static int initialBufferSize()
public TierRecordType type()
type
in class AbstractTierMetadata
public TopicIdPartition topicIdPartition()
AbstractTierMetadata
topicIdPartition
in class AbstractTierMetadata
public int tierEpoch()
AbstractTierMetadata
tierEpoch
in class AbstractTierMetadata
public OffsetAndEpoch stateOffsetAndEpoch()
AbstractTierMetadata
stateOffsetAndEpoch
in class AbstractTierMetadata
public OffsetAndEpoch snapshotOffsetAndEpoch()
public Optional<org.apache.kafka.raft.OffsetAndEpoch> partitionCreationOffsetAndEpoch()
public ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public UUID messageId()
AbstractTierMetadata
messageId
in class AbstractTierMetadata
public long snapshotTimestampMs()
public Algorithm checksumAlgorithm()
public byte version()