public class HeapWatcher extends Object implements kafka.server.BrokerReconfigurable, NotificationFilter, NotificationListener
Modifier and Type | Field and Description |
---|---|
static scala.collection.Set<String> |
reconfigurableConfigs
BrokerReconfigurable
|
Modifier and Type | Method and Description |
---|---|
void |
handleNotification(Notification notification,
Object handback) |
static HeapWatcher |
instanceForBean(MemoryPoolMXBean bean,
org.apache.kafka.common.metrics.Metrics metrics,
kafka.server.KafkaConfig kafkaConfig) |
boolean |
isNotificationEnabled(Notification notification) |
static Optional<HeapWatcher> |
maybeCreateHeapWatcher(org.apache.kafka.common.metrics.Metrics metrics,
kafka.server.KafkaConfig kafkaConfig)
Creates a HeapWatcher for the tenured pool.
|
scala.collection.Set<String> |
reconfigurableConfigs() |
void |
reconfigure(kafka.server.KafkaConfig oldConfig,
kafka.server.KafkaConfig newConfig) |
void |
shutdown() |
void |
validateReconfiguration(kafka.server.KafkaConfig newConfig) |
public static scala.collection.Set<String> reconfigurableConfigs
public static Optional<HeapWatcher> maybeCreateHeapWatcher(org.apache.kafka.common.metrics.Metrics metrics, kafka.server.KafkaConfig kafkaConfig)
public static HeapWatcher instanceForBean(MemoryPoolMXBean bean, org.apache.kafka.common.metrics.Metrics metrics, kafka.server.KafkaConfig kafkaConfig)
public boolean isNotificationEnabled(Notification notification)
isNotificationEnabled
in interface NotificationFilter
public void handleNotification(Notification notification, Object handback)
handleNotification
in interface NotificationListener
public void shutdown()
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