BrokerReconfigurable¶

BrokerReconfigurable is an abstraction of dynamic reconfigurables that can be reconfigured at runtime.

Contract¶

Reconfigurable Configs¶

reconfigurableConfigs: Set[String]

Used when:

• DynamicBrokerConfig is requested to addBrokerReconfigurable and processReconfiguration

validateReconfiguration¶

validateReconfiguration(
  newConfig: KafkaConfig): Unit

Validates the updated KafkaConfig

Used when:

• DynamicBrokerConfig is requested to processReconfiguration

Reconfiguring Broker¶

reconfigure(
  oldConfig: KafkaConfig,
  newConfig: KafkaConfig): Unit

Used when:

• DynamicBrokerConfig is requested to updateCurrentConfig

Implementations¶

• DynamicListenerConfig
• DynamicLogConfig
• DynamicThreadPool
• LogCleaner
• SocketServer