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