public class TierTopicManagerCommitter extends Object
Modifier and Type | Field and Description |
---|---|
static kafka.tier.TierTopicManagerCommitter.VersionInfo |
CURRENT_VERSION |
Constructor and Description |
---|
TierTopicManagerCommitter(TierTopicManagerConfig config,
kafka.server.LogDirFailureChannel logDirFailureChannel)
Instantiate a TierTopicManagerCommitter
|
Modifier and Type | Method and Description |
---|---|
OffsetAndEpoch |
positionFor(int partitionId)
Return the current position and epoch for the given tier topic partition.
|
Map<Integer,OffsetAndEpoch> |
takePositionsSnapshot()
Take a snapshot of the current positions for all Tier Topic partitions.
|
void |
updatePosition(int partition,
OffsetAndEpoch updateTo)
Update position materialized by the TierTopicManager consumer.
|
void |
writePositionsSnapshot(Map<Integer,OffsetAndEpoch> positions) |
public static final kafka.tier.TierTopicManagerCommitter.VersionInfo CURRENT_VERSION
public TierTopicManagerCommitter(TierTopicManagerConfig config, kafka.server.LogDirFailureChannel logDirFailureChannel)
config
- TierTopicManagerConfig containing tiering configurationlogDirFailureChannel
- Log dir failure channelpublic void updatePosition(int partition, OffsetAndEpoch updateTo)
partition
- Tier Topic partitionIdupdateTo
- Tier Topic Partition position and epochpublic OffsetAndEpoch positionFor(int partitionId)
partitionId
- tier topic partition idpublic Map<Integer,OffsetAndEpoch> takePositionsSnapshot()
public void writePositionsSnapshot(Map<Integer,OffsetAndEpoch> positions)