AdminZkClient¶

Creating Instance¶

AdminZkClient takes the following to be created:

• KafkaZkClient

AdminZkClient is created when:

• ConfigCommand is requested to processCommandWithZk
• DynamicBrokerConfig is requested to initialize
• KafkaServer is requested to start up
• ZkAdminManager is created (adminZkClient)
• ZkConfigManager is created (adminZkClient)
• ZkConfigRepository is created (adminZkClient)

fetchEntityConfig¶

fetchEntityConfig(
  rootEntityType: String,
  sanitizedEntityName: String): Properties

fetchEntityConfig requests the KafkaZkClient to getEntityConfigs.

fetchEntityConfig is used when:

• FIXME

changeEntityConfig¶

changeEntityConfig(
  rootEntityType: String,
  fullSanitizedEntityName: String,
  configs: Properties): Unit

changeEntityConfig...FIXME

changeEntityConfig is used when:

• AdminZkClient is requested to changeClientIdConfig, changeUserOrUserClientIdConfig, changeIpConfig, changeTopicConfig, changeBrokerConfig

changeTopicConfig¶

changeTopicConfig(
  topic: String,
  configs: Properties): Unit

changeTopicConfig...FIXME

changeTopicConfig is used when:

• ZkAdminManager is requested to alterTopicConfigs
• AdminZkClient is requested to changeConfigs

changeConfigs¶

changeConfigs(
  entityType: String,
  entityName: String,
  configs: Properties): Unit

changeConfigs...FIXME

changeConfigs is used when:

• ConfigCommand is requested to alterConfigWithZk
• ZkAdminManager is requested to alterClientQuotas, alterUserScramCredentials