public class TierTopicManagerCommitter
extends java.lang.Object
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.
|
java.lang.Long |
positionFor(int partitionId)
Return the current position for the given tier topic partition.
|
void |
updatePosition(java.lang.Integer partition,
java.lang.Long position)
Update position materialized by the TierTopicManager consumer.
|
public TierTopicManagerCommitter(TierTopicManagerConfig config, kafka.server.LogDirFailureChannel logDirFailureChannel)
config
- TierTopicManagerConfig containing tiering configurationlogDirFailureChannel
- Log dir failure channelpublic void updatePosition(java.lang.Integer partition, java.lang.Long position)
partition
- Tier Topic partitionIdposition
- Tier Topic Partition positionpublic java.lang.Long positionFor(int partitionId)
partitionId
- tier topic partition idpublic void flush(java.util.Iterator<TierPartitionState> tierPartitionStateIterator)