public class TierPartitionStateFactory extends Object
Constructor and Description |
---|
TierPartitionStateFactory(boolean tierFeatureEnabled,
boolean tierChecksumFeatureEnabled) |
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) |
TierPartitionState |
initState(File stateDir,
org.apache.kafka.common.TopicPartition topicPartition,
kafka.log.LogConfig config,
kafka.server.LogDirFailureChannel logDirFailureChannel,
kafka.utils.Scheduler scheduler,
Boolean tierChecksumState) |
boolean |
mayEnableTiering(org.apache.kafka.common.TopicPartition topicPartition,
kafka.log.LogConfig config) |
public TierPartitionStateFactory(boolean tierFeatureEnabled, boolean tierChecksumFeatureEnabled)
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 TierPartitionState initState(File stateDir, org.apache.kafka.common.TopicPartition topicPartition, kafka.log.LogConfig config, kafka.server.LogDirFailureChannel logDirFailureChannel, kafka.utils.Scheduler scheduler, Boolean tierChecksumState) throws IOException
IOException
public boolean mayEnableTiering(org.apache.kafka.common.TopicPartition topicPartition, kafka.log.LogConfig config)