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,
long tierTopicPartitionOffset)
Process metadata for this context.
|
TierPartitionStatus |
status()
Retrieve status of tiered partition.
|
TierPartitionState.AppendResult process(AbstractTierMetadata metadata, long tierTopicPartitionOffset)
metadata
- Metadata to processtierTopicPartitionOffset
- Metadata's offset in TierTopicPartitionTierPartitionStatus status()
void beginCatchup()
TierPartitionStatus.CATCHUP
phase for this context.void completeCatchup()
TierPartitionStatus.ONLINE
status.