public class DiskIOManager extends Object implements ResourceUsageManager, Runnable, kafka.server.BrokerReconfigurable
Modifier and Type | Field and Description |
---|---|
static org.apache.kafka.common.MetricName |
DISK_THROUGHPUT_BYTE_PER_SEC
metrics
|
static org.apache.kafka.common.MetricName |
DISK_THROUGHPUT_LIMIT_BYTE_PER_SEC |
static long |
INVALID_THROUGHPUT_THRESHOLD |
static scala.collection.Set<String> |
reconfigurableConfigs
dynamic configs
|
Modifier and Type | Method and Description |
---|---|
void |
applyQuota() |
boolean |
isThrottled() |
static Optional<DiskIOManager> |
maybeInitDiskIOManager(org.apache.kafka.common.metrics.Metrics metrics,
kafka.server.KafkaConfig config,
Optional<kafka.metrics.LinuxDiskMetricsCollector> linuxDiskMetricsCollectorOpt) |
scala.collection.Set<String> |
reconfigurableConfigs() |
void |
reconfigure(kafka.server.KafkaConfig oldConfig,
kafka.server.KafkaConfig newConfig) |
void |
registerListener(ResourceUsageListener listener) |
void |
run() |
void |
shutdown() |
void |
startup() |
void |
updateUsage() |
void |
validateReconfiguration(kafka.server.KafkaConfig newConfig) |
public static final long INVALID_THROUGHPUT_THRESHOLD
public static final org.apache.kafka.common.MetricName DISK_THROUGHPUT_BYTE_PER_SEC
public static final org.apache.kafka.common.MetricName DISK_THROUGHPUT_LIMIT_BYTE_PER_SEC
public static scala.collection.Set<String> reconfigurableConfigs
public static Optional<DiskIOManager> maybeInitDiskIOManager(org.apache.kafka.common.metrics.Metrics metrics, kafka.server.KafkaConfig config, Optional<kafka.metrics.LinuxDiskMetricsCollector> linuxDiskMetricsCollectorOpt)
public void startup()
public void shutdown()
public void updateUsage()
updateUsage
in interface ResourceUsageManager
public void applyQuota()
applyQuota
in interface ResourceUsageManager
public void registerListener(ResourceUsageListener listener)
registerListener
in interface ResourceUsageManager
public boolean isThrottled()
public scala.collection.Set<String> reconfigurableConfigs()
reconfigurableConfigs
in interface kafka.server.BrokerReconfigurable
public void validateReconfiguration(kafka.server.KafkaConfig newConfig)
validateReconfiguration
in interface kafka.server.BrokerReconfigurable
public void reconfigure(kafka.server.KafkaConfig oldConfig, kafka.server.KafkaConfig newConfig)
reconfigure
in interface kafka.server.BrokerReconfigurable