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