Package org.apache.kafka.common
Class DelegatingReconfigurable
java.lang.Object
org.apache.kafka.common.DelegatingReconfigurable
- All Implemented Interfaces:
Configurable
,Reconfigurable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Configure this class with the given key-value pairsReturns the names of configs that may be reconfigured.void
reconfigure
(Map<String, ?> configs) Reconfigures this instance with the given key-value pairs.void
validateReconfiguration
(Map<String, ?> configs) Validates the provided configuration.
-
Constructor Details
-
DelegatingReconfigurable
-
-
Method Details
-
reconfigurableConfigs
Description copied from interface:Reconfigurable
Returns the names of configs that may be reconfigured.- Specified by:
reconfigurableConfigs
in interfaceReconfigurable
-
validateReconfiguration
Description copied from interface:Reconfigurable
Validates the provided configuration. The provided map contains all configs including any reconfigurable configs that may be different from the initial configuration. Reconfiguration will be not performed if this method throws any exception.- Specified by:
validateReconfiguration
in interfaceReconfigurable
- Throws:
ConfigException
- if the provided configs are not valid. The exception message from ConfigException will be returned to the client in the AlterConfigs response.
-
reconfigure
Description copied from interface:Reconfigurable
Reconfigures this instance with the given key-value pairs. The provided map contains all configs including any reconfigurable configs that may have changed since the object was initially configured usingConfigurable.configure(Map)
. This method will only be invoked if the configs have passed validation usingReconfigurable.validateReconfiguration(Map)
.- Specified by:
reconfigure
in interfaceReconfigurable
-
configure
Description copied from interface:Configurable
Configure this class with the given key-value pairs- Specified by:
configure
in interfaceConfigurable
-