Skip to content

AdminZkClient

Creating Instance

AdminZkClient takes the following to be created:

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:

changeTopicConfig

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

changeTopicConfig...FIXME


changeTopicConfig is used when:

changeConfigs

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

changeConfigs...FIXME


changeConfigs is used when: