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

reconfigure(oldConfig: KafkaConfig, newConfig: KafkaConfig): Unit
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

results matching ""

    No results matching ""