Skip to content

KafkaZkClient

getEntityConfigs

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

getEntityConfigs talks to Zookeeper for config data in the /config/[entityType]/[entityName] znode.

$ ./bin/zkCli.sh -server localhost:2181 ls /config
[brokers, changes, clients, ips, topics, users]

getEntityConfigs is used when:

createConfigChangeNotification

createConfigChangeNotification(
  sanitizedEntityPath: String): Unit

createConfigChangeNotification...FIXME

createConfigChangeNotification is used when: