public static interface TierTopicConsumer.ClientCtx
Modifier and Type | Method and Description |
---|---|
void |
beginCatchup()
Begin
TierPartitionStatus.CATCHUP phase for this context. |
void |
completeCatchup()
Complete catchup phase for this context and transition to
TierPartitionStatus.ONLINE status. |
default long |
materializationLag()
Retrieve lag of tiered partition.
|
TierPartitionState.AppendResult |
process(AbstractTierMetadata metadata,
OffsetAndEpoch sourceOffsetAndEpoch)
Process metadata for this context.
|
TierPartitionState.RestoreResult |
processRestoreEvents(AbstractTierMetadata metadata,
TierPartitionStatus targetStatus,
OffsetAndEpoch sourceOffsetAndEpoch,
Optional<ByteBuffer> targetStateOpt)
Process restore events for this context
|
TierPartitionStatus |
status()
Retrieve status of tiered partition.
|
TierPartitionState.AppendResult process(AbstractTierMetadata metadata, OffsetAndEpoch sourceOffsetAndEpoch)
metadata
- Metadata to processsourceOffsetAndEpoch
- Offset and epoch corresponding to metadata to processTierPartitionState.RestoreResult processRestoreEvents(AbstractTierMetadata metadata, TierPartitionStatus targetStatus, OffsetAndEpoch sourceOffsetAndEpoch, Optional<ByteBuffer> targetStateOpt)
metadata
- TierPartitionForceRestore or TierPartitionUnfreezeLogStartOffset event being restoredtargetStatus
- TierPartitionStatus to restore the TierPartitionState atsourceOffsetAndEpoch
- Offset and epoch corresponding to metadata to processtargetStateOpt
- buffer containing the TierPartitionState contents to recoverTierPartitionStatus status()
default long materializationLag()
void beginCatchup()
TierPartitionStatus.CATCHUP
phase for this context.void completeCatchup()
TierPartitionStatus.ONLINE
status.