code: def load_topology_config(self):
          
          config_path = os.path.join(
              self.kafka_topology_path,
              '{id}.yaml'.format(id=self.cluster_type),
          )
          self.log.debug("Loading configuration from %s", config_path)
          if os.path.isfile(config_path):
              topology_config = load_yaml_config(config_path)
          else:
              raise MissingConfigurationError(
                  "Topology configuration {0} for cluster {1} "
                  "does not exist".format(
                      config_path,
                      self.cluster_type,
                  )
              )
          self.log.debug("Topology configuration %s", topology_config)
          try:
              self.clusters = topology_config['clusters']
          except KeyError:
              self.log.exception("Invalid topology file")
              raise InvalidConfigurationError("Invalid topology file {0}".format(
                  config_path))
          if 'local_config' in topology_config:
              self.local_config = topology_config['local_config']
docs: Load the topology configuration