reconfigure(
oldConfig: KafkaConfig,
newConfig: KafkaConfig): Unit
DynamicListenerConfig
DynamicListenerConfig is a BrokerReconfigurable for the following dynamic configurations:
DynamicListenerConfig is created exclusively when DynamicBrokerConfig is requested to addReconfigurables (when KafkaServer is requested to start up).
DynamicListenerConfig takes a single KafkaServer to be created.
Reconfiguring — reconfigure Method
|
Note
|
reconfigure is part of the BrokerReconfigurable Contract to change (reconfigure) the value of a Kafka dynamic configuration.
|
reconfigure…FIXME
If there are any listeners added or removed, reconfigure requests the LoginManager to closeAll.
reconfigure requests the KafkaServer for the SocketServer that is in turn requested to removeListeners with the listeners removed.
reconfigure requests the KafkaServer for the SocketServer that is in turn requested to addListeners with the listeners added.
In the end, reconfigure requests the KafkaServer for the KafkaController that is in turn requested to updateBrokerInfo with the new createBrokerInfo.
validateReconfiguration Method
validateReconfiguration(
newConfig: KafkaConfig): Unit
|
Note
|
validateReconfiguration is part of the BrokerReconfigurable Contract to…FIXME.
|
validateReconfiguration…FIXME