ConfigHandler Contract

package kafka.server

trait ConfigHandler {
  def processConfigChanges(entityName: String, value: Properties)
}
Table 1. ConfigHandler Contract
Property Description

processConfigChanges

Used when DynamicConfigManager is requested to start up, processEntityConfigChangeVersion1, processEntityConfigChangeVersion2

Table 2. ConfigHandlers
ConfigHandler Description

BrokerConfigHandler

ClientIdConfigHandler

TopicConfigHandler

UserConfigHandler

results matching ""

    No results matching ""