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. |
TierPartitionState.AppendResult |
process(AbstractTierMetadata metadata,
OffsetAndEpoch sourceOffsetAndEpoch)
Process metadata for this context.
|
TierPartitionState.RestoreResult |
restoreState(TierPartitionForceRestore metadata,
java.nio.ByteBuffer targetState,
TierPartitionStatus targetStatus,
OffsetAndEpoch sourceOffsetAndEpoch)
Process restore 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 restoreState(TierPartitionForceRestore metadata, java.nio.ByteBuffer targetState, TierPartitionStatus targetStatus, OffsetAndEpoch sourceOffsetAndEpoch)
metadata
- TierPartitionForceRestore metadata being restoredtargetState
- buffer containing the TierPartitionState contents to recovertargetStatus
- TierPartitionStatus to restore the TierPartitionState atsourceOffsetAndEpoch
- Offset and epoch corresponding to metadata to processTierPartitionStatus status()
void beginCatchup()
TierPartitionStatus.CATCHUP
phase for this context.void completeCatchup()
TierPartitionStatus.ONLINE
status.