public class BrokerConfigChangeListener extends Object implements kafka.server.BrokerReconfigurable
Constructor and Description |
---|
BrokerConfigChangeListener(ZKTopicMetadataCollector zkTopicMetadataCollector,
int nodeId) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Set<String> |
reconfigurableConfigs() |
void |
reconfigure(kafka.server.KafkaConfig oldConfig,
kafka.server.KafkaConfig newConfig) |
void |
validateReconfiguration(kafka.server.KafkaConfig newConfig) |
public BrokerConfigChangeListener(ZKTopicMetadataCollector zkTopicMetadataCollector, int nodeId)
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