public class TierTopicManagerCommitter
extends java.lang.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 |
---|---|
void |
flush(java.util.Iterator<TierPartitionState> tierPartitionStateIterator)
Flush TierPartition files to disk and then write consumer offsets to disk.
|
OffsetAndEpoch |
positionFor(int partitionId)
Return the current position and epoch for the given tier topic partition.
|
void |
updatePosition(int partition,
OffsetAndEpoch updateTo)
Update position materialized by the TierTopicManager consumer.
|
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 void flush(java.util.Iterator<TierPartitionState> tierPartitionStateIterator)