public class TierPartitionStateFactory extends Object
Constructor and Description |
---|
TierPartitionStateFactory(boolean tierFeatureEnabled) |
Modifier and Type | Method and Description |
---|---|
TierPartitionState |
initState(File stateDir,
org.apache.kafka.common.TopicPartition topicPartition,
kafka.log.LogConfig config,
kafka.server.LogDirFailureChannel logDirFailureChannel,
kafka.utils.Scheduler scheduler) |
boolean |
mayEnableTiering(org.apache.kafka.common.TopicPartition topicPartition,
kafka.log.LogConfig config) |
public TierPartitionStateFactory(boolean tierFeatureEnabled)
public TierPartitionState initState(File stateDir, org.apache.kafka.common.TopicPartition topicPartition, kafka.log.LogConfig config, kafka.server.LogDirFailureChannel logDirFailureChannel, kafka.utils.Scheduler scheduler) throws IOException
IOException
public boolean mayEnableTiering(org.apache.kafka.common.TopicPartition topicPartition, kafka.log.LogConfig config)