BrokerReconfigurable Contract — Reconfigurable Broker Services

BrokerReconfigurable is the contract of reconfigurable broker services that allow for self-reconfiguration.

BrokerReconfigurable interface is used exclusively by DynamicBrokerConfig.

Table 1. BrokerReconfigurable Contract
Property Description

reconfigurableConfigs

reconfigurableConfigs: Set[String]

Used when DynamicBrokerConfig is requested to addBrokerReconfigurable and processReconfiguration

reconfigure

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

Used exclusively when DynamicBrokerConfig is requested to updateCurrentConfig

validateReconfiguration

validateReconfiguration(newConfig: KafkaConfig): Unit

Used exclusively when DynamicBrokerConfig is requested to processReconfiguration

Table 2. BrokerReconfigurables (Direct Implementations)
BrokerReconfigurable Description

DynamicListenerConfig

DynamicThreadPool

LogCleaner

results matching ""

    No results matching ""